JDBC数据库访问与事务处理

　　paragraph…
　　paragraph…

jdbc访问数据库的步骤：

1. 获取到数据库的用户名、密码、连接字符串，

2. 用Class.forName或者其他方法来注册驱动，获得ConnectionManager，

3. 再用ConnectionManager通过连接字符串、用户名、密码，获取到Connection连接，

4. 通过Connection获得Statement处理对象或者PreparedStatement预处理对象，

5. 操作完毕后，先关闭statement对象再关闭Connection连接。

jdbc如何做事务处理？

首先，设置jdbc的自动提交为false；
然后，使用数据库连接，开启一个事务transaction；
接着，对数据库进行多条增删改操作，并添加异常捕获try-catch；
操作完毕后，进行commit事务提交，并在catch代码块中使用事务回滚rollback功能；
最后，在finally代码块中关闭数据库连接。

jdbc入门

/* 以查找全部记录为例 */

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
//首先导入mysql的jdbc包
import com.mysql.jdbc.Driver;

public class JdbcTest {
    @Test
    public void process(){
        Connection conn = null; // 创建连接对象
        Statement stmt = null;    // 创建能执行SQL语句的Statement对象
        ResultSet rs = null; // 创建SQL语句执行结果返回对象

        try {//异常捕获
            // 1.通过jdbc包中的Driver类来注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2.通过DriverManager以及连接参数获取链接Connection
            conn = DriverManager.getConnection("jdbc:mysql:///DBname", "username", "password"); //参数：数据库连接字符串、用户名、密码
            // 3.由Connection开启事务 --设置默认提交为false
            conn.setAutoCommit(false);
            // 4.由Connection创建能执行SQL语句的Statement对象
            stmt = conn.createStatement();//或PreparedStatement预处理对象
            // 5.编写SQL语句并执行
            String sql = "select * from t_user";
            // 执行SQL语句获得结果集
            rs = stmt.executeQuery(sql);
            // 遍历查询结果集rs获取数据
            while(rs.next()){
                // 拿出来
                int id =rs.getInt("id");
                String username = rs.getString("username");
                String password = rs.getString("password");
                System.out.println(id+" "+username+" "+password);
            }
            // 6.手动提交事务
            conn.commit();
        } catch (Exception e) { //ClassNotFoundException、SQLException
            // 7.若发生异常  回滚事务（对于增删改）
            try {
                conn.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace(); //打印异常信息
            throw new RuntimeException(e);
        }
        finally{
            // 8.释放资源
            /** 释放资源的标准文档代码: */
            // 8.1先关闭执行SQL语句的结果返回对象ResultSet
            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                rs = null;
            }
            // 8.2然后再关闭能执行SQL语句的Statement对象
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            // 8.3最后关闭链接
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                conn = null;
            }
        }
    }
}