一个SESSION所进行的全部更新操做要么一块儿成功,要么一块儿失败java
举个例子:A向B转帐,转帐这个流程中若是出现问题,事务可让数据恢复成原来同样【A帐户的钱没变,B帐户的钱也没变】。sql
事例说明:数据库
/* * 咱们来模拟A向B帐号转帐的场景 * A和B帐户都有1000块,如今我让A帐户向B帐号转500块钱 * * */
//JDBC默认的状况下是关闭事务的,下面咱们看看关闭事务去操做转帐操做有什么问题
//A帐户减去500块
String sql = "UPDATE a SET money=money-500 ";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.executeUpdate();
//B帐户多了500块
String sql2 = "UPDATE b SET money=money+500";
preparedStatement = connection.prepareStatement(sql2);
preparedStatement.executeUpdate();
复制代码
从上面看,咱们的确能够发现A向B转帐,成功了。但是**若是A向B转帐的过程当中出现了问题呢?**下面模拟一下微信
//A帐户减去500块
String sql = "UPDATE a SET money=money-500 ";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.executeUpdate();
//这里模拟出现问题
int a = 3 / 0;
String sql2 = "UPDATE b SET money=money+500";
preparedStatement = connection.prepareStatement(sql2);
preparedStatement.executeUpdate();
复制代码
显然,上面代码是会抛出异常的,咱们再来查询一下数据。A帐户少了500块钱,B帐户的钱没有增长。这明显是不合理的。ide
咱们能够经过事务来解决上面出现的问题工具
//开启事务,对数据的操做就不会当即生效。
connection.setAutoCommit(false);
//A帐户减去500块
String sql = "UPDATE a SET money=money-500 ";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.executeUpdate();
//在转帐过程当中出现问题
int a = 3 / 0;
//B帐户多500块
String sql2 = "UPDATE b SET money=money+500";
preparedStatement = connection.prepareStatement(sql2);
preparedStatement.executeUpdate();
//若是程序能执行到这里,没有抛出异常,咱们就提交数据
connection.commit();
//关闭事务【自动提交】
connection.setAutoCommit(true);
} catch (SQLException e) {
try {
//若是出现了异常,就会进到这里来,咱们就把事务回滚【将数据变成原来那样】
connection.rollback();
//关闭事务【自动提交】
connection.setAutoCommit(true);
} catch (SQLException e1) {
e1.printStackTrace();
}
复制代码
上面的程序也同样抛出了异常,A帐户钱没有减小,B帐户的钱也没有增长。this
注意:当Connection遇到一个未处理的SQLException时,系统会非正常退出,事务也会自动回滚,但若是程序捕获到了异常,是须要在catch中显式回滚事务的。spa
咱们还可使用savepoint设置中间点。若是在某地方出错了,咱们设置中间点,回滚到出错以前便可。code
应用场景:如今咱们要算一道数学题,算到后面发现算错数了。前面的运算都是正确的,咱们不可能重头再算【直接rollback】,最好的作法就是在保证前面算对的状况下,设置一个保存点。从保存点开始从新算。对象
注意:savepoint不会结束当前事务,普通提交和回滚都会结束当前事务的
数据库定义了4个隔离级别:
分别对应Connection类中的4个常量
脏读:一个事务读取到另一个事务未提交的数据
例子:A向B转帐,A执行了转帐语句,但A尚未提交事务,B读取数据,发现本身帐户钱变多了!B跟A说,我已经收到钱了。A回滚事务【rollback】,等B再查看帐户的钱时,发现钱并无多。
不可重复读:一个事务读取到另一个事务已经提交的数据,也就是说一个事务能够看到其余事务所作的修改
注:A查询数据库获得数据,B去修改数据库的数据,致使A屡次查询数据库的结果都不同【危害:A每次查询的结果都是受B的影响的,那么A查询出来的信息就没有意思了】
虚读(幻读):是指在一个事务内读取到了别的事务插入的数据,致使先后读取不一致。
注:和不可重复读相似,但虚读(幻读)会读到其余事务的插入的数据,致使先后读取不一致
简单总结:脏读是不可容忍的,不可重复读和虚读在必定的状况下是能够的【作统计的确定就不行】。
元数据其实就是数据库,表,列的定义信息
即便咱们写了一个简单工具类,咱们的代码仍是很是冗余。对于增删改而言,只有SQL和参数是不一样的,咱们为什么不把这些相同的代码抽取成一个方法?对于查询而言,不一样的实体查询出来的结果集是不同的。咱们要使用元数据获取结果集的信息,才能对结果集进行操做。
问题:咱们对数据库的增删改查都要链接数据库,关闭资源,获取PreparedSteatment对象,获取Connection对象此类的操做,这样的代码重复率是极高的,因此咱们要对工具类进行加强
//咱们发现,增删改只有SQL语句和传入的参数是不知道的而已,因此让调用该方法的人传递进来
//因为传递进来的参数是各类类型的,并且数目是不肯定的,因此使用Object[]
public static void update(String sql, Object[] objects) {
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null;
try {
connection = getConnection();
preparedStatement = connection.prepareStatement(sql);
//根据传递进来的参数,设置SQL占位符的值
for (int i = 0; i < objects.length; i++) {
preparedStatement.setObject(i + 1, objects[i]);
}
//执行SQL语句
preparedStatement.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
复制代码
/* 1:对于查询语句来讲,咱们不知道对结果集进行什么操做【经常使用的就是把数据封装成一个Bean对象,封装成一个List集合】 2:咱们能够定义一个接口,让调用者把接口的实现类传递进来 3:这样接口调用的方法就是调用者传递进来实现类的方法。【策略模式】 */
//这个方法的返回值是任意类型的,因此定义为Object。
public static Object query(String sql, Object[] objects, ResultSetHandler rsh) {
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null;
try {
connection = getConnection();
preparedStatement = connection.prepareStatement(sql);
//根据传递进来的参数,设置SQL占位符的值
if (objects != null) {
for (int i = 0; i < objects.length; i++) {
preparedStatement.setObject(i + 1, objects[i]);
}
}
resultSet = preparedStatement.executeQuery();
//调用调用者传递进来实现类的方法,对结果集进行操做
return rsh.hanlder(resultSet);
}
复制代码
接口:
/* * 定义对结果集操做的接口,调用者想要对结果集进行什么操做,只要实现这个接口便可 * */
public interface ResultSetHandler {
Object hanlder(ResultSet resultSet);
}
复制代码
实现类:
//接口实现类,对结果集封装成一个Bean对象
public class BeanHandler implements ResultSetHandler {
//要封装成一个Bean对象,首先要知道Bean是什么,这个也是调用者传递进来的。
private Class clazz;
public BeanHandler(Class clazz) {
this.clazz = clazz;
}
@Override
public Object hanlder(ResultSet resultSet) {
try {
//建立传进对象的实例化
Object bean = clazz.newInstance();
if (resultSet.next()) {
//拿到结果集元数据
ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
for (int i = 0; i < resultSetMetaData.getColumnCount(); i++) {
//获取到每列的列名
String columnName = resultSetMetaData.getColumnName(i+1);
//获取到每列的数据
String columnData = resultSet.getString(i+1);
//设置Bean属性
Field field = clazz.getDeclaredField(columnName);
field.setAccessible(true);
field.set(bean,columnData);
}
//返回Bean对象
return bean;
}
复制代码
【策略模式】简单理解:
咱们并不知道调用者想对结果集进行怎么样的操做,因而让调用者把想要作的操做对象传递过来
咱们只要用传递过来的对象对结果集进行封装就行了。
对我我的理解,策略模式就是咱们在使用别人API时,可使用匿名内部类的时候。别人用的就是策略模式。
若是文章有错的地方欢迎指正,你们互相交流。习惯在微信看技术文章的同窗,能够关注微信公众号:Java3y