有关jdbc以及JDBC事务的相关操作

Posted 2020-11-25 nrcy

有关jdbc及jdbc事务的操作

 一，什么是JDBC

*Java数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。我们通常说的JDBC是面向关系型数据库的。 --以上来自百度百科。*

 二，JDBC的本质

本质上jdbc就是一套接口，我们需要面向接口编程，而不是面向具体的类，达到解耦合的目的，各大数据库厂商 如oracle，mysql，SqlServer都实现了jdbc接口方便我们调用。

*jdbc的接口就在，java.sql 包下*

## 三，JDBC步骤

- jdbc可以划分为6步，既：

1，注册数据库驱动

2，获取数据库连接对象

3，获取数据库操作对象

4，执行sql语句

5，处理查询结果集 *（注意 如果执行的sql语句是dml涉及增删改，则不需要这一步）*

6，关闭资源

## 四，JDBC代码

以下是需要处理查询结果集的

package top.nrcynet;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class Demo {
    public static void main(String[] args) {
        
        String url = "";
        String user = "";
        String password = "";
        
        String sql = "select * from test.employee";
        
        Connection conn = null;
        Statement stat = null;
        ResultSet rs = null;
        
        try {
            //注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            
            //获取数据库连接对象
            conn = DriverManager.getConnection(url, user, password);
            
            //获取数据库操作对象
            stat = conn.createStatement();
            
            //执行sql语句
            rs = stat.executeQuery(sql);
            
            //处理查询结果集
            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                String address = rs.getString("address");
                int departmentId = rs.getInt("department_id");
                System.out.println(id + "	" + name + "	" + address + "	" + departmentId);
            }
            
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }finally {
            //关闭资源
            if(rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(stat != null) {
                try {
                    stat.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        
        
    }
}

以下是不需要处理查询结果集的

package top.nrcynet;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class Demo02 {
public static void main(String[] args) {
        
        String url = "";
        String user = "";
        String password = "";
        
        String sql = "insert into test.employee(name,address,department_id) values(?,?,?)";
        
        Connection conn = null;
        PreparedStatement ps = null;
        
        try {
            
            //注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            
            //获取数据库连接对象
            conn = DriverManager.getConnection(url, user, password);
            //设置不自动提交事务
            conn.setAutoCommit(false);
            
            //获取数据库预处理操作对象
            ps = conn.prepareStatement(sql);
            
            
            ps.setString(1, "张伟");
            ps.setString(2, "北京市");
            ps.setInt(3, 2);
            
            ps.execute();
            
            //手动提交事务
            conn.commit();
        } catch (ClassNotFoundException | SQLException e) {
            try {
                //程序报错，事务回滚
                conn.rollback();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            e.printStackTrace();
        }finally {
            //关闭资源
            
            if(ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        
        
    }
}

 

- 关于代码：

* 1.java.sql.PreparedStatement,是一个具有预处理功能的接口，该接口可以有效防止sql注入事件的发生。在sql语句中用 "?" 占位符占位，利用该接口中的setString，setInt等方法给占位符传值，此方法第一个参数为从1开始的占位符位数，第二个参数为具体要传的值

* 2.在处理查询结果集中利用java.sql.ResultSet的实例可以遍历出数据，类似集合。利用next方法可以判断当当前行是否有值，并将索引指针指向下一行。利用该接口中的例如：getStirng,getInt等方法传入一个参数取值，该参数为当前列的字段名，或者从1开始的字段位数

## 五，关于事务

在java.sql.Connection接口中可以完成对事务的提交和混滚的基本操作，该接口中的setAutoCommit方法可以设置是否自动提交事务，默认是true，自动提交，同时该接口中也有commit，rollback方法进行提交和混滚的操作 以上就是jdbc的基本操作，源代码也提交到github，[点击这里查看源码](https://github.com/nrcy/jdbcDemo)

中国加油，武汉加油