JDBC第三篇--【事务、元数据、改造JDBC工具类】

时间 2019-11-21

标签 jdbc 第三事务数据改造工具栏目 Java 繁體版

原文原文链接

这是我JDBC的第一篇java

http://blog.csdn.net/hon_3y/article/details/53535798sql

这是我JDBC的第二篇
http://blog.csdn.net/hon_3y/article/details/53725446数据库

1.事务

一个SESSION所进行的全部更新操做要么一块儿成功，要么一块儿失败markdown

举个例子:A向B转帐，转帐这个流程中若是出现问题，事务可让数据恢复成原来同样【A帐户的钱没变，B帐户的钱也没变】。ide

事例说明：工具

/* * 咱们来模拟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转帐的过程当中出现了问题呢？下面模拟一下this

//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帐户的钱没有增长。这明显是不合理的。spa

咱们能够经过事务来解决上面出现的问题.net

//开启事务,对数据的操做就不会当即生效。
            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帐户的钱也没有增长。code

注意：当Connection遇到一个未处理的SQLException时，系统会非正常退出，事务也会自动回滚，但若是程序捕获到了异常，是须要在catch中显式回滚事务的。

savapoint

咱们还可使用savepoint设置中间点。若是在某地方出错了，咱们设置中间点，回滚到出错以前便可。

应用场景：如今咱们要算一道数学题，算到后面发现算错数了。前面的运算都是正确的，咱们不可能重头再算【直接rollback】，最好的作法就是在保证前面算对的状况下，设置一个保存点。从保存点开始从新算。

注意：savepoint不会结束当前事务，普通提交和回滚都会结束当前事务的

事务的隔离级别

数据库定义了4个隔离级别：

Serializable【可避免脏读，不可重复读，虚读】
Repeatable read【可避免脏读，不可重复读】
Read committed【可避免脏读】
Read uncommitted【级别最低，什么都避免不了】

分别对应Connection类中的4个常量

TRANSACTION_READ_UNCOMMITTED
TRANSACTION_READ_COMMITTED
TRANSACTION_REPEATABLE_READ
TRANSACTION_SERIALIZABLE

脏读：一个事务读取到另一个事务未提交的数据

例子：A向B转帐，A执行了转帐语句，但A尚未提交事务，B读取数据，发现本身帐户钱变多了！B跟A说，我已经收到钱了。A回滚事务【rollback】，等B再查看帐户的钱时，发现钱并无多。

不可重复读：一个事务读取到另一个事务已经提交的数据，也就是说一个事务能够看到其余事务所作的修改

注：A查询数据库获得数据，B去修改数据库的数据，致使A屡次查询数据库的结果都不同【危害：A每次查询的结果都是受B的影响的，那么A查询出来的信息就没有意思了】

虚读(幻读)：是指在一个事务内读取到了别的事务插入的数据，致使先后读取不一致。

注：和不可重复读相似，但虚读(幻读)会读到其余事务的插入的数据，致使先后读取不一致

简单总结：脏读是不可容忍的，不可重复读和虚读在必定的状况下是能够的【作统计的确定就不行】。

2.元数据

什么是元数据

元数据其实就是数据库，表，列的定义信息

为何咱们要用元数据

即便咱们写了一个简单工具类，咱们的代码仍是很是冗余。对于增删改而言，只有SQL和参数是不一样的，咱们为什么不把这些相同的代码抽取成一个方法？对于查询而言，不一样的实体查询出来的结果集是不同的。咱们要使用元数据获取结果集的信息，才能对结果集进行操做。

ParameterMetaData –参数的元数据
ResultSetMetaData –结果集的元数据
DataBaseMetaData –数据库的元数据

3.改造JDBC工具类

问题：咱们对数据库的增删改查都要链接数据库，关闭资源，获取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;
            }