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

有关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 + "\t" + name + "\t" + address + "\t" + 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)

中国加油,武汉加油