Java EE WEB工程师培训-JDBC+Servlet+JSP整合开发之08.JDBC可更新的ResultSet及RowSet
–设置可滚动ResultSet –滚动ResultSet –更新ResultSet –RowSet ####################Michael分割线####################### • 设置可滚动ResultSet –为了获得可滚动ResultSet，我们必须用如下的方式来创建Statement或者PreparedSatement • 滚动ResultSet –rs.previous() –rs.relatice(n) –rs.absolute(n) –rs.getRow() –rs.first() –rs.last() –rs.beforeFirst() –rs.afterLast() –rs.isFirst() –rs.isLast() –rs.isBeforeFirst() –rs.isAfterLast() ConnectionUtil.java packagecom.michael.jdbc; importjava.sql.Connection; importjava.sql.DriverManager; importjava.util.Properties; public classConnectionUtil { //第一种方法 publicConnection getConnection(){ Connection conn = null; try{ //Class.forName加载驱动 Class.forName( "com.mysql.jdbc.Driver"); //DriverManager获得连接 conn = DriverManager.getConnection( "jdbc:mysql://localhost:3306/jdbc_db","root","mysqladmin"); returnconn; }catch(Exception e) { e.printStackTrace(); } returnnull; } //第二种方法 publicConnection getConnection(String driver,String url,String user,String password){ Connection conn =null; try{ //Class.forName加载驱动 Class.forName(driver); //DriverManager获得连接 conn = DriverManager.getConnection(url,user,password); returnconn; }catch(Exception e) { e.printStackTrace(); } returnnull; } //第三种方法 publicConnection openConnection(){ String driver = ""; String url = ""; String user = ""; String password = ""; Properties prop =newProperties(); Connection conn =null; try{ //加载属性文件 prop.load(this.getClass().getClassLoader().getResourceAsStream("DBConfig.properties")); driver = prop.getProperty("driver"); url = prop.getProperty("url"); user = prop.getProperty("user"); password = prop.getProperty("password"); //Class.forName加载驱动 Class.forName(driver); //DriverManager获得连接 conn = DriverManager.getConnection(url,user,password); returnconn; }catch(Exception e) { e.printStackTrace(); } returnnull; } } TestResultSet.java packagecom.michael.jdbc; importjava.sql.Connection; importjava.sql.ResultSet; importjava.sql.SQLException; importjava.sql.Statement; public classTestResultSet { public static voidtest(){ Connection conn = newConnectionUtil().openConnection(); try{ Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); //执行查询获得结果集 ResultSet rs = stmt.executeQuery( "select * from UserTbl"); //定义行号 rs.next(); //相对定位 rs.relative(3); //绝对定位 rs.absolute(2); //移动游标到第一行 booleanb = rs.first(); booleanb2 = rs.last(); introwNumber = rs.getRow(); //输出行号,即游标位置 System.out.println(rowNumber); System.out.println(b); System.out.println(b2); } catch(SQLException e) { e.printStackTrace(); } } } Main.java packagecom.michael.main; importcom.michael.jdbc.TestResultSet; public classMain { /** * @param args */ public static voidmain(String[] args) { TestResultSet.test(); } } • 更新ResultSet –更新一行 更新第四条记录 TestResultSet.java packagecom.michael.jdbc; importjava.sql.Connection; importjava.sql.ResultSet; importjava.sql.SQLException; importjava.sql.Statement; public classTestResultSet { public static voidtest(){ Connection conn = newConnectionUtil().openConnection(); try{ Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); //执行查询获得结果集 ResultSet rs = stmt.executeQuery( "select * from UserTbl"); //绝对定位到第四条记录 rs.absolute(4); rs.updateString(2, "alibaba"); rs.updateString(3, "alimama"); //更新一行 rs.updateRow(); /* //定义行号 rs.next(); //相对定位 rs.relative(3); //绝对定位 rs.absolute(2); //移动游标到第一行 boolean b = rs.first(); boolean b2 = rs.last(); int rowNumber = rs.getRow(); //输出行号,即游标位置 System.out.println(rowNumber); System.out.println(b); System.out.println(b2); */ } catch(SQLException e) { e.printStackTrace(); } } } Main.java packagecom.michael.main; importcom.michael.jdbc.TestResultSet; public classMain { /** * @param args */ public static voidmain(String[] args) { TestResultSet.test(); } } –插入一行 TestResultSet.java packagecom.michael.jdbc; importjava.sql.Connection; importjava.sql.ResultSet; importjava.sql.SQLException; importjava.sql.Statement; public classTestResultSet { public static voidtest(){ Connection conn = newConnectionUtil().openConnection(); try{ Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); //执行查询获得结果集 ResultSet rs = stmt.executeQuery( "select * from UserTbl"); //插入一行 rs.moveToInsertRow(); rs.updateString(2, "Jake"); rs.updateString(3, "123456"); rs.updateInt(4, 26); rs.insertRow(); /* 更新一行 //绝对定位到第四条记录 rs.absolute(4); rs.updateString(2, "alibaba"); rs.updateString(3, "alimama"); //更新一行 rs.updateRow(); */ /* //定义行号 rs.next(); //相对定位 rs.relative(3); //绝对定位 rs.absolute(2); //移动游标到第一行 boolean b = rs.first(); boolean b2 = rs.last(); int rowNumber = rs.getRow(); //输出行号,即游标位置 System.out.println(rowNumber); System.out.println(b); System.out.println(b2); */ } catch(SQLException e) { e.printStackTrace(); } } } • RowSet –可更新的ResultSet是强大的，但是在操作期间必须保持数据处于连接状态 –RowSet接口继承了ResultSet，提供了如下的实现类： • CachedRowSet: 允许断开连接操作 • WebRowSet: 能保存XML文件 • FilteredRowSet/JoinRowSet: 在rowset上SELECT/JOIN操作 • JdbcRowSet: 可以将一行封装为一个Java Bean ####################Michael分割线####################### 附件：http://down.51cto.com/data/2352859 本文转自redking51CTO博客，原文链接：http://blog.51cto.com/redking/163778，如需转载请自行联系原作者
