JDBC 常见使用：
- 加载驱动
Class.forName("com.mysql.jdbc.Driver");
- 获取数据库连接
public static Connection getCon() {
// MySQ的URL格式 jdbc:mysql://主机名:端口号/数据库名
final String url = "jdbc:mysql://localhost:3306/test";
final String user = "root";
final String pass = "root";
Connection con = null;
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 获取数据库连接
con = DriverManager.getConnection(url, user, pass);
}
catch (Exception e) {
e.printStackTrace();
}
return con;
}
- 使用 executeQuery 方法执行SQL的查询语句
public static void QueryDemo() throws SQLException {
// 获取数据库连接
Connection con = getCon();
// 准备sql语句
String sql = "select * from users where ssex = '女'";
// 获取状态
Statement state = con.createStatement();
// 提交查询的sql语句
ResultSet set = state.executeQuery(sql);
// 处理结果
while(set.next()) {
String name = set.getString("user_name");
int age = set.getInt("sage");
System.out.println("姓名：" + name + "， 年龄：" + age);
}
// 释放资源
if (set != null) {
set.close();
}
if (con != null) {
con.close();
}
}
- 使用 executeUpdate 方法执行更新的SQL语句（增速改）
public static int UpdataDemo() throws SQLException {
int row = -1;
// 获取连接
Connection con = getCon();
// 准备sql语句
String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
// 获取状态
Statement state = con.createStatement();
// 提交更新(增、删、改)SQL语句
row = state.executeUpdate(sql);
// 处理结果
System.out.println("影响行数：" + row);
// 释放资源
con.close();
return row;
}
- execute 方法增删查改都可以提交
public static void executeDemo() throws SQLException {
// 获取连接
Connection con = getCon();
// 准备sql语句
String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
// 获取状态
Statement state = con.createStatement();
// 提交更新(增、删、查、改)SQL语句
boolean isResult = state.execute(sql);
if (isResult == true) {
// 获取结果集
ResultSet set = state.getResultSet();
// 处理结果
// 省略。。。
}
else {
// 获取影响行数
int row = state.getUpdateCount();
System.out.println("影响行数：" + row);
}
}
- 使用 preparStatement 预编译状态执行SQL语句
public static int preExceuteDemo(String name, String pass) throws SQLException {
int row = -1;
// 获取连接
Connection con = getCon();
// 准备sql
String sql = "UPDATE users SET user_pass = ? WHERE user_name = ?";
// 获取预编译状态
PreparedStatement state = con.prepareStatement(sql);
// 设置参数
state.setString(1, pass);
state.setString(2, name);
// 提交sql语句
row = state.executeUpdate();
// 处理结果
System.out.println("影响行数：" + row);
// 释放资源
state.close();
return row;
}
- 使用 CallableStatement 状态 调用存储过程
public static String callPreDemo(String name) throws SQLException {
String id = null;
// 获取数据库连接
Connection con = getCon();
// 准备调用存储过程的sql语句
String sql = "{call p_getid(?, ?)}";
// 获取 callable 预编译状态
CallableStatement state = con.prepareCall(sql);
// 设置参数
state.setString(1, name);
// 声明输出参数类型
state.registerOutParameter(2, java.sql.Types.VARCHAR);
// 执行存储过程
state.execute();
// 获取存储过程输出参数
id = state.getString(2);
// 处理结果
System.out.println(name + "的用户id为：" + id);
// 释放资源
state.close();
return id;
}
事务
// 关闭自动提交，提交了 SQL 语句不会立即生效，需要自己手动提交。
con.setAutoCommit(false);
// 手动提交
con.commit();
// 回滚
con.rollback();
完整代码
package com.woniuxy.jdbcdemo;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.CallableStatement;
import java.sql.Connection;
public class JDBCDemo {
public static void main(String[] args) {
try {
// QueryDemo();
// UpdataDemo();
// preExceuteDemo("张三", "zs123");
callPreDemo("王五");
} catch (SQLException e) {
e.printStackTrace();
}
}
public static Connection getCon() {
// jdbc:mysql://主机名:端口号/数据库名
final String url = "jdbc:mysql://localhost:3306/test";
final String user = "root";
final String pass = "root";
Connection con = null;
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 获取数据库连接
con = DriverManager.getConnection(url, user, pass);
}
catch (Exception e) {
e.printStackTrace();
}
return con;
}
public static void QueryDemo() throws SQLException {
// 获取数据库连接
Connection con = getCon();
// 准备sql语句
String sql = "select * from users where ssex = '女'";
// 获取状态
Statement state = con.createStatement();
// 提交查询的sql语句
ResultSet set = state.executeQuery(sql);
// 处理结果
while(set.next()) {
String name = set.getString("user_name");
int age = set.getInt("sage");
System.out.println("姓名：" + name + "， 年龄：" + age);
}
// 释放资源
if (set != null) {
set.close();
}
if (con != null) {
con.close();
}
}
public static int UpdataDemo() throws SQLException {
int row = -1;
// 获取连接
Connection con = getCon();
// 准备sql语句
String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
// 获取状态
Statement state = con.createStatement();
// 提交更新(增、删、改)SQL语句
row = state.executeUpdate(sql);
// 处理结果
System.out.println("影响行数：" + row);
// 释放资源
con.close();
return row;
}
public static void executeDemo() throws SQLException {
// 获取连接
Connection con = getCon();
// 准备sql语句
String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
// 获取状态
Statement state = con.createStatement();
// 提交更新(增、删、查、改)SQL语句
boolean isResult = state.execute(sql);
if (isResult == true) {
// 获取结果集
ResultSet set = state.getResultSet();
// 处理结果
}
else {
// 获取影响行数
int row = state.getUpdateCount();
System.out.println("影响行数：" + row);
}
}
public static int preExceuteDemo(String name, String pass) throws SQLException {
int row = -1;
// 获取连接
Connection con = getCon();
// 准备sql
String sql = "UPDATE users SET user_pass = ? WHERE user_name = ?";
// 获取预编译状态
PreparedStatement state = con.prepareStatement(sql);
// 设置参数
state.setString(1, pass);
state.setString(2, name);
// 提交sql语句
row = state.executeUpdate();
// 处理结果
System.out.println("影响行数：" + row);
// 释放资源
state.close();
return row;
}
public static String callPreDemo(String name) throws SQLException {
String id = null;
// 获取数据库连接
Connection con = getCon();
// 准备调用存储过程的sql语句
String sql = "{call p_getid(?, ?)}";
// 获取 callable 预编译状态
CallableStatement state = con.prepareCall(sql);
// 设置参数
state.setString(1, name);
// 声明输出参数类型
state.registerOutParameter(2, java.sql.Types.VARCHAR);
// 执行存储过程
state.execute();
// 获取存储过程输出参数
id = state.getString(2);
// 处理结果
System.out.println(name + "的用户id为：" + id);
// 释放资源
state.close();
return id;
}
}
