JDBC
一、JDBC访问数据库步骤
面试回答：
①加载JDBC驱动
②创建数据库连接（Connection）
③创建SQL命令发送器Statement或者preparedStatement
④执行Sql语句
⑤访问结果集ResultSet对象
⑥依次将ResultSet对象，Statement/PreparedStatement，Connection对象关闭，释放资源
代码演示：
//properties文件
mysqlDriver=com.mysql.jdbc.Driver
mysqlURL=jdbc\:mysql\://localhost\:3306/testjdbc
mysqlUser=root
mysqlPwd=123456
oracleDriver=oracle.jdbc.driver.OracleDriver
oracleURL=jdbc\:oracle\:thin\:@localhost\:1521\:orcl
oracleUser=scott
oraclePwd=tiger
---------------------------------------------------------------------------
//测试类
/**
* 测试使用JDBCUtil工具类来简化JDBC开发
* @author 高淇 www.sxt.cn
*
*/
public class Demo11 {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JDBCUtil.getMysqlConn();
ps = conn.prepareStatement("insert into t_user (username) values (?)");
ps.setString(1, "gaoqi");
ps.execute();
} catch (Exception e) {
e.printStackTrace();
}finally{
JDBCUtil.close(rs, ps, conn);
}
}
}
-------------------------------------------------------------------------
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
//JDBCUtil
public class JDBCUtil {
static Properties pros = null; //可以帮助读取和处理资源文件中的信息
static { //加载JDBCUtil类的时候调用
pros = new Properties();
try {
pros.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("db.properties"));
} catch (IOException e) {
e.printStackTrace();
}
}
public static Connection getMysqlConn(){
try {
Class.forName(pros.getProperty("mysqlDriver"));
return DriverManager.getConnection(pros.getProperty("mysqlURL"),
pros.getProperty("mysqlUser"),pros.getProperty("mysqlPwd"));
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
public static Connection getOracleConn(){
try {
Class.forName(pros.getProperty("oracleDriver"));
return DriverManager.getConnection(pros.getProperty("oracleURL"),
pros.getProperty("oracleUser"),pros.getProperty("oraclePwd"));
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
public static void close(ResultSet rs,Statement ps,Connection conn){
try {
if(rs!=null){
rs.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(ps!=null){
ps.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(conn!=null){
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void close(Statement ps,Connection conn){
try {
if(ps!=null){
ps.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(conn!=null){
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void close(Connection conn){
try {
if(conn!=null){
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
二、步骤详解---JDBC连接数据库
1.加载驱动
加载JDBC驱动是通过调用方法java.langClass.forName()，常用的几种数据库驱动程序
加载语句的形式 :
Class.forName(“oracle.JDBC.driver.OracleDriver”)；//使用Oracle的JDBC驱动程序 Class.forName(“com.microsoft.JDBC.sqlserver.SQLServerDriver”)；//使用SQL Server的JDBC驱 动程序
Class.forName(“com.ibm.db2.JDBC.app.DB2Driver”)；//使用DB2的JDBC驱动程序 Class.forName("com.mysql.JDBC.Driver");//使用MySql的JDBC驱动程序
2.创建数据库连接
与数据库建立连接的方法是调用DriverManager.getConnection(String url, String user, String password )方法 。
• Connection conn=null;
• String url="jdbc:oracle:thin:@localhost:1521:orcl";
• String user=“scott";
• String password=“tiger";
• conn = DriverManager.getConnection(url, user, password);
3.创建SQL命令发送器Statement或者preparedStatement
Statement对象用于将 SQL 语句发送到数据库中，或者理解为执行sql语句
有三种 Statement对象：
Statement：用于执行不带参数的简单SQL语句；
PreparedStatement（从 Statement 继承）：用于执行带或不带参数的预编译SQL语句；
CallableStatement（从PreparedStatement 继承）：用于执行数据库存储过程的调用。
| 方法 | 作用 |
|---|---|
| ResultSet executeQuery(String sql) | 可以执行插入、删除、更新等操作，返回值是执行该操作所影 响的行数 |
| boolean execute(String sql) | 可以执行任意SQL语句，然后获得一个布尔值，表示是否返回ResultSet |
| int executeUpdate(String sql) | 执行SQL查询并获取到ResultSet对象 |
4.处理ResultSet结果
①ResultSet对象是executeQuery()方法的返回值，它被称为结果集，它代表符合SQL语句条件的
所有行，并且它通过一套getXXX方法（这些get方法可以访问当前行中的不同列）提供了对这
些行中数据的访问。
②ResultSet里的数据一行一行排列，每行有多个字段，且有一个记录指针，指针所指的数据行
叫做当前数据行，我们只能来操作当前的数据行。我们如果想要取得某一条记录，就要使用
ResultSet的next()方法 ,如果我们想要得到ResultSet里的所有记录，就应该使用while循环。
③ResultSet对象自动维护指向当前数据行的游标。每调用一次next()方法，游标向下移动一行
④初始状态下记录指针指向第一条记录的前面，通过next()方法指向第一条记录。循环完毕后
指向最后一条记录的后面。
| 方法名 | 说明 |
|---|---|
| boolean next() | 将光标从当前位置向下移动一行 |
| boolean previous() | 游标从当前位置向上移动一行 |
| void close() | 关闭ResultSet对象 |
| int getInt(int colIndex) | 以int形式获取结果集当前行指定列号值 |
| int getInt(String colLabel) | 以int形式获取结果集当前行指定列名值 |
| float getFloat(int colIndex) | 以float形式获取结果集当前行指定列号值 |
| float getFloat(String colLabel) | 以float形式获取结果集当前行指定列名值 |
| String getString(int colIndex) | 以String 形式获取结果集当前行指定列号值 |
| String getString(String colLabel) | 以String形式获取结果集当前行指定列名值 |
5.关闭数据库资源
①关闭Statement对象和Connection对象的语法形式为：
public void close() throws SQLException
②用户不必关闭ResultSet。当它的 Statement 关闭、重新执行或用于从多结果序列中获取下一
个结果时，该ResultSet将被自动关闭。
③注意：要按先ResultSet结果集，后Statement，最后Connection的顺序关闭资源，因为
Statement和ResultSet是需要连接是才可以使用的，所以在使用结束之后有可能其他的
Statement还需要连接，所以不能先关闭Connection.
三、使用PreparedStatement完善JDBC操作
1. 基本概念及使用
PreparedStatement 接口继承 Statement接口。
如果需要多次执行一个SQL语句，可以使用PreparedStatement对象。在创建 PreparedStatement对象时，通过传递不同参数值多次执行PreparedStatement对象，可 以得到多个不同的结果。
优势：执行效率高、代码可读性强、安全性高
该对象用Connection的prepareStatement()方法创建。
例如：
• pstmt=conn.prepareStatement("insert into student values(?,?,? )");
• pstmt.setString(1, “小明");
• pstmt.setInt(2, 27);
• pstmt.setFloat(3, 85);
• pstmt.executeUpdate()；
2. PreparedStatement接口中的主要方法
void setString (int parameterIndex, String x)
void setFloat (int parameterIndex, float x)
void setInt (int parameterIndex, int x)
void setDate (int parameterIndex, java.sql.Date x)
void setDouble (int parameterIndex, double x)
ResultSet executeQuery () //返回单结果集，通常用于SELECT语句
boolean execute () //返回布尔值，通常用于insert，update，delete语句
int executeUpdate () //返回操作影响的行数，通常用于insert，update，delete语句
四、JDBC事物管理
一条对数据库的更新表达式代表一项事务操作 操作成功后，系统将自动调用commit()提交，否则调用rollback()回滚。可以通过调用setAutoCommit(false)来禁止自动提交。之后就可以把多个数据库操作的表达式作为
一个事务，在操作完成后调用commit()来进行整体提交。倘若其中一个表达式操作失败，都不会执行到commit()，并且将产生响应的异常。
try {
stmt = conn.createStatement();
conn.setAutoCommit(false);
String sql1 ="update account set balance = balance-1000 where aid=1";
String sql2 ="update account set balance = balance+1000 where aid=2"; stmt.executeUpdate(sql1);
stmt.executeUpdate(sql2);
conn.commit();
} catch (SQLException e) {
try {
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}
