mysqlresultsetdemo.java

jbuilder2006一书的所有源代码

package table;

import java.sql.*;

public class MySQLResultSetDemo {

  public static void main(String[] args) throws Exception {
    //定义数据库连接的驱动程序
    String driver = "org.gjt.mm.mysql.Driver";
    //告诉程序使用jdbc与odbc桥创建数据库连接
    Class.forName(driver);
    //定义MySQL数据库的连接地址,作用是连接books数据库
    String url = "jdbc:mysql://localhost:3306/books?user=root;password=";
    Connection conn;
    //使用DriverManager类的getConnection()方法建立连接,
    //第一个字符参数定义用户名,第二个字符参数定义密码
    conn = DriverManager.getConnection(url, "", "");
    //创建可以前后移动，和可以进行更新的Statement接口
    Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                          ResultSet.CONCUR_UPDATABLE);
    //获取数据表的全部记录
    String sql = "select * from bookcategory";
    ResultSet rs = stmt.executeQuery(sql);
    //插入记录操作
    rs.moveToInsertRow();
    //写入字段值
    rs.updateInt(1, 14);
    rs.updateString(2, "新增加的图书类别14");
    rs.updateString(3, "图书类别14的描述");
    //向数据库提交插入的记录
    try{
      rs.insertRow();
      System.out.println("成功插入记录");
    }catch(Exception e){
      System.out.println("插入记录失败");
    }
    //重新取得数据表的记录
    rs = stmt.executeQuery(sql);
    //将指针移到第14条记录
    rs.absolute(14);
    //显示第14条记录的数据
    System.out.println("新插入的记录：");
    System.out.println(rs.getString(1) + "  " + rs.getString(2) + "  " + rs.getString(3));
    //执行更新操作
    rs.updateString(1, "14");
    rs.updateString(2, "新增加的图书类别14(更改)");
    rs.updateString(3, "图书类别14的描述(更改)");
    //向数据库提交更新的记录
    rs.updateRow();
    //重新取得数据表的记录
    rs = stmt.executeQuery(sql);
    rs.absolute(14);
    //显示第14条记录的数据
    System.out.println("更改后的记录：");
    System.out.println(rs.getString(1) + "  " + rs.getString(2) + "  " + rs.getString(3));
    try{
      //删除第14条记录
      rs.deleteRow();
      System.out.println("成功删除记录");
    }catch(Exception e){
      e.printStackTrace();
    }
    //关闭数据集和数据库连接
    rs.close();
    conn.close();
  }
}