有关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代码
写代码之前需要导入相关的jar，可以去maven仓库中下载
以下代码为查询操作，既需要处理查询结果集
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，点击这里查看源码
中国加油，武汉加油
