行集
一、什么行集
前面两篇文章介绍了结果集,但是存在一个缺点,当用户访问结果集的时候不能断开数据库连接,为了解决这个问题,出现了行集。增删改查都可以在行集中进行。
二、行集更改数据库的方法
①获取连接参数
②得到是操作指令
③得到结果
④更改行集
⑤更改数据库
注:当关闭数据库后,数据库中的数据得到修改,这时更改后的行集是不能更改数据库的。
三、创建行集及其操作的代码
Course课程类
package TestRowSet; public class Course { private String courseno; private String coursename; public String getCoursename() { return coursename; } public void setCoursename(String coursename) { this.coursename = coursename; } public String getCourseno() { return courseno; } public void setCourseno(String courseno) { this.courseno = courseno; } @Override public String toString() { return "Course{" + "courseno='" + courseno + '\'' + ", coursename='" + coursename + '\'' + '}'; } }
数据库连接
package TestRowSet; import java.io.IOException; import java.io.InputStream; import java.nio.file.Files; import java.nio.file.Paths; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.Properties; public class Dao { private static InputStream in = null; private static Properties pope = new Properties(); //读取数据库配置文件 private static Connection conn = null; //获得连接 public static Connection getConnectoin() { try { in = Files.newInputStream(Paths.get("E:\\IdeaWorkSpace\\database.properties")); pope.load(in); String driver = pope.getProperty("jdbc.drivers"); String url = pope.getProperty("jdbc.url"); String username = pope.getProperty("jdbc.username"); String password = pope.getProperty("jdbc.password"); conn = DriverManager.getConnection(url, username, password); } catch (IOException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn; } public static void closeConnecton() { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }
行集建立与操作
package TestRowSet; import com.sun.rowset.CachedRowSetImpl; import javax.sql.rowset.CachedRowSet; import javax.sql.rowset.RowSetFactory; import javax.sql.rowset.RowSetProvider; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; /** * @date:2017/11/29 * @time:19:35 * 功能:测试行集,行集比结果集最大的有点是,在操作的过才能中可以关闭数据库 */ public class RowSet { public static void main(String[] args){ Connection conn = Dao.getConnectoin(); //得到链接 Statement stat = null; ResultSet rs = null; RowSetFactory factory = null; //相当于一个行集工厂 Course course = new Course(); //课程信息 String select = "select * from t_course;"; try { //第一种实现方法 stat = conn.createStatement(); //获得链接活动 factory = RowSetProvider.newFactory(); //获得这个工厂对象 CachedRowSet crs = factory.createCachedRowSet(); //得到行集 //crs.setPageSize(2); rs = stat.executeQuery(select); crs.populate(rs); //将结果集压入行集 conn.close(); // int i = 1; // while(crs.nextPage()){ //必须是行集自己查找 // System.out.println("第" + i + "页"); // i++; while(crs.next()){ course.setCourseno(crs.getString("courseno")); course.setCoursename(crs.getString("coursename")); String s = course.toString(); System.out.println(s); } //} } catch (SQLException e) { e.printStackTrace(); } try { //第二种实现方法,当无法实现RowSetProvider的时候使用 CachedRowSet crs = new CachedRowSetImpl(); crs.setUrl("jdbc:mysql://localhost:3306/student"); //获得链接数据库的信息 crs.setUsername("root"); crs.setPassword("123456"); crs.setCommand(select); crs.setPageSize(2); //设置页面最大为2 crs.execute(); int i = 1; do { //必须是行集自己查找 System.out.println("第" + i + "页"); i++; while(crs.next()){ course.setCourseno(crs.getString("courseno")); //获得信息 course.setCoursename(crs.getString("coursename")); String s = course.toString(); System.out.println(s); } }while(crs.nextPage()); //判断是否还有下一页 } catch (SQLException e) { e.printStackTrace(); } finally { try { conn.close(); stat.close(); } catch (SQLException e) { e.printStackTrace(); } } } }
四、事务
事务:由多个语句组成,主要为了确保数据库完整性。事务可以回滚。
创建及处理事务的流程:
①在设计事务之前,关闭数据库的自动提交模式,只要被提交到数据库就无法回滚。
conn.setAutoCommit(false); //关闭默认更新
②执行所有的操作
包括增删改查
③提交事务
conn.comit(); //提交
④检查是否出错,出错回滚
conn.rollback() //回滚
在设计的时候可设计保存点,使得回滚更加的精确,回滚的时候只需要回滚到保存点即可不需要回滚到事务的开头。
Savepoint svpt = conn.setSavepoint(); //设计保存点
conn.rollback(svpt); //回滚到保存点
批量更新
应用事务可以实现批量更新,在这之前要检查数据库是否支持这种操作
DatabaseMetaData 接口中的supportsBatchUpdate方法可以得到这个信息。
在批量更新中添加select语句会抛出异常
实现:
stat.addBatch(command);
....... //添加更新操作
stat.executeBatch();
如果出错,回滚到批量更新之前的状态。
五、元数据
三类元数据:关于数据库的元数据、关于结果集的元数据、关于预备语句参数的元数据。
所谓元数据,就是描述数据库或其组成部分的数据,比如列名、表名等。
获得DatabaseMetaDate对象, DatabaseMetaData meta = conn.getMetaData();
关于对元数据的具体的操作,可以参考API,了解更多的方法。这里只是简单建立一种概念。