有关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)
中国加油,武汉加油
原文地址:https://www.cnblogs.com/nrcy/p/12331778.html