JDBC数据库的使用操作总结_MySQL
bitsCN.com
JDBC是一组能够执行SQL语句的API
由于传统的数据库操作方式需要程序员掌握各个不同的数据库的API，极其不便
因此java定义了JDBC这一标准的接口和类，为程序员操作数据库提供了统一的方式
JDBC的操作方式比较单一，由五个流程组成：
1.通过数据库厂商提供的JDBC类库向DriverManager注册数据库驱动
2.使用DriverManager提供的getConnection()方法连接到数据库
3.通过数据库的连接对象的createStatement方法建立SQL语句对象
4.执行SQL语句，并将结果集合返回到ResultSet中
5.使用while循环读取结果
6.关闭数据库资源
下面来看看具体操作Mysql数据库的方法
准备工作
首先我们需要建立一个数据库和一张简单的表
mysql> create database person;
Query OK, 1 row affected (0.00 sec)
mysql> use person;
Database changed
mysql> create table student(
-> id int,
-> name varchar(20),
-> birth year
-> ) default charset=utf8;
Query OK, 0 rows affected (0.10 sec)
然后往里面插入几条数据
mysql> insert into student values
-> (1,'张三',1990),
-> (2,'李四',1991),
-> (3,'王五',1992);
Query OK, 3 rows affected (0.02 sec)
Records: 3 Duplicates: 0 Warnings: 0
这样一张简单的表就建好了
mysql> select * from student;
+------+--------+-------+
| id | name | birth |
+------+--------+-------+
| 1 | 张三 | 1990 |
| 2 | 李四 | 1991 |
| 3 | 王五 | 1992 |
+------+--------+-------+
rows in set (0.00 sec)
接下来，去mysql官网下载数据库连接器这个包
其中这个包里面含有一份文档，里面列举了基本的使用方法，可以参考
我们的操作也是按照这份文档中的内容进行，然后最主要的地方就是导入这个jar包
为了操作方便，这里使用eclipse来导入
右键项目-->构件路径-->添加外部归档，添加好了之后如下所示
现在我们正式开始使用java来操作mysql数据库
JDBC操作实例1：最简单的查询操作
import java.sql.*;
public class Demo {
//为了代码紧凑性，暂时抛出所有异常
public static void main(String[] args) throws Exception {
//注册数据库驱动
Class.forName("com.mysql.jdbc.Driver");
//建立数据库连接
//参数一：jdbc：mysql//地址：端口/数据库,参数二：用户名，参数三：密码
Connection conn = DriverManager.getConnection
("jdbc:mysql://localhost:3306/person","root","admin");
//创建SQL语句
Statement st = conn.createStatement();
//执行语句，返回结果
ResultSet rt = st.executeQuery("show tables");
//循环取出结果
while(rt.next()) {
//获取字段
System.out.println(rt.getString("Tables_in_person"));
}
//关闭资源，最先打开的最后关
rt.close();
st.close();
conn.close();
}
}
运行结果：student
如此便可执行show tables语句查询出当前数据库含有多少张表
其中rt.getString()方法是获取字段，这点需要注意
关闭资源的方式也与以往相反
不过，上面的操作方式灵活性不大，并且不严谨
实例2：优化的查询操作
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 = "jdbc:mysql://localhost:3306/person";
String user = "root";
String pwd = "admin";
String sql = "select * from student";
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url,user,pwd);
st = conn.createStatement();
//执行查询语句，另外也可以用execute()，代表执行任何SQL语句
rs = st.executeQuery(sql);
while(rs.next()) {
System.out.println(rs.getObject(1) + " " +
rs.getObject(2) + " " + rs.getInt("birth"));
}
//分别捕获异常
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
//判断资源是否存在
if(rs != null) {
rs.close();
//显示的设置为空，提示gc回收
rs = null;
}
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
运行结果：
这里把异常给分别捕获了，并且相关的字符串全部用变量定义
需要注意下循环取出数据里面的getInt()方法，此处必须知道类型和字段才能取出
如果不知道可以使用getObject(1)取出第一列，getObject(2)取出第二列，以此类推
实例3：自定义变量插入到数据库
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class Demo {
public static void main(String[] args) {
//参数检查
if (args.length != 3) {
System.out.println("参数形式不对");
System.exit(0);
}
String id = args[0];
String name = args[1];
String birth = args[2];
String sql = "insert into student values(" + id + ",'" + name +
"'," + "'" + birth + "')";
System.out.println(sql);
String url = "jdbc:mysql://localhost:3306/person";
String user = "root";
String pwd = "admin";
Connection conn = null;
Statement st = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url,user,pwd);
st = conn.createStatement();
//注意，此处是excuteUpdate()方法执行
st.executeUpdate(sql);
//分别捕获异常
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
运行结果：
这里运行需要设置自变量，窗口中右键-->运行方式-->运行配置
然后在自变量里面写4 susan 1993，我没有写中文，因为产生乱码，目前还不清楚原因
需要注意的是，执行插入的SQL语句比较难写，最好是打印出SQL语句用以检查
实例4：PreparedStatement应用
从上面的Demo可以看到，插入数据的时候，SQL操作相当不便
这里可以使用PreparedStatement对象来简化SQL语句的建立
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Demo {
public static void main(String[] args) {
if (args.length != 3) {
System.out.println("参数形式不对");
System.exit(0);
}
String id = args[0];
String name = args[1];
String birth = args[2];
String url = "jdbc:mysql://localhost:3306/person";
String user = "root";
String pwd = "admin";
Connection conn = null;
//声明PreparedStatement对象的引用
PreparedStatement pst = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url,user,pwd);
//使用？代替变量
pst = conn.prepareStatement("insert into student values (?,?,?)");
//给指定参数的位置设定变量
pst.setString(1, id);
pst.setString(2, name);
pst.setString(3, birth);
pst.executeUpdate();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if(pst != null) {
pst.close();
pst = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
运行结果：
实例5：Batch批处理
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class Demo {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/person";
String user = "root";
String pwd = "admin";
Connection conn = null;
Statement st = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url,user,pwd);
st = conn.createStatement();
//添加批处理
st.addBatch("insert into student values(6,'Jerry','1995')");
st.addBatch("insert into student values(7,'Greg','1996')");
st.addBatch("insert into student values(8,'Ryan','1997')");
//执行批处理
st.executeBatch();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
运行结果：
批处理比较简单，只需先建立Statement对象，然后逐个添加批处理即可
最后使用executeBatch()方法执行批处理
此外，PreparedStatement对象也可以使用批处理
PreparedStatement ps = conn.prepareStatement("insert into student values(?,?,?)");
ps.setInt(1,8);
ps.setString(2,"GG");
ps.setString(3,"1996");
ps.addBatch();
ps.executeBatch();
实例6：Transaction事务处理
事务处理是要求sql以单元的形式更新数据库，要求其确保一致性
如银行的转账业务，一方转出后，另一方则增加
如果出现异常，那么所有的操作则会回滚
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class Demo {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/person";
String user = "root";
String pwd = "admin";
Connection conn = null;
Statement st = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url,user,pwd);
//取消自动提交
conn.setAutoCommit(false);
st = conn.createStatement();
st.addBatch("insert into student values(6,'Jerry','1995')");
st.addBatch("insert into student values(7,'Greg','1996')");
st.addBatch("insert into student values(8,'Ryan','1997')");
st.executeBatch();
//提交后设置自动提交
conn.commit();
conn.setAutoCommit(true);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
if(conn != null) {
try {
//出现异常则回滚操作，然后设置自动提交
conn.rollback();
conn.setAutoCommit(true);
} catch (SQLException e1) {
e1.printStackTrace();
}
}
} finally {
try {
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
运行结果：
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發環境
Dreamweaver CS6
視覺化網頁開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
突破或從Java 8流返回？
Feb 07, 2025 pm 12:09 PM
Java 8引入了Stream API，提供了一種強大且表達力豐富的處理數據集合的方式。然而，使用Stream時，一個常見問題是：如何從forEach操作中中斷或返回？ 傳統循環允許提前中斷或返回，但Stream的forEach方法並不直接支持這種方式。本文將解釋原因，並探討在Stream處理系統中實現提前終止的替代方法。 延伸閱讀： Java Stream API改進 理解Stream forEach forEach方法是一個終端操作，它對Stream中的每個元素執行一個操作。它的設計意圖是處
PHP：網絡開發的關鍵語言
Apr 13, 2025 am 12:08 AM
PHP是一種廣泛應用於服務器端的腳本語言，特別適合web開發。 1.PHP可以嵌入HTML，處理HTTP請求和響應，支持多種數據庫。 2.PHP用於生成動態網頁內容，處理表單數據，訪問數據庫等，具有強大的社區支持和開源資源。 3.PHP是解釋型語言，執行過程包括詞法分析、語法分析、編譯和執行。 4.PHP可以與MySQL結合用於用戶註冊系統等高級應用。 5.調試PHP時，可使用error_reporting()和var_dump()等函數。 6.優化PHP代碼可通過緩存機制、優化數據庫查詢和使用內置函數。 7
PHP中的抽像類和接口有什麼區別？
Apr 08, 2025 am 12:08 AM
抽像類和接口的主要區別在於：抽像類可以包含方法的實現，而接口只能定義方法的簽名。 1.抽像類使用abstract關鍵字定義，可包含抽象和具體方法，適合提供默認實現和共享代碼。 2.接口使用interface關鍵字定義，只包含方法簽名，適合定義行為規範和多重繼承。
Java程序查找膠囊的體積
Feb 07, 2025 am 11:37 AM
膠囊是一種三維幾何圖形，由一個圓柱體和兩端各一個半球體組成。膠囊的體積可以通過將圓柱體的體積和兩端半球體的體積相加來計算。本教程將討論如何使用不同的方法在Java中計算給定膠囊的體積。 膠囊體積公式 膠囊體積的公式如下： 膠囊體積 = 圓柱體體積 兩個半球體體積 其中， r: 半球體的半徑。 h: 圓柱體的高度（不包括半球體）。 例子 1 輸入 半徑 = 5 單位 高度 = 10 單位 輸出 體積 = 1570.8 立方單位 解釋 使用公式計算體積： 體積 = π × r2 × h (4
PHP與Python：了解差異
Apr 11, 2025 am 12:15 AM
PHP和Python各有優勢，選擇應基於項目需求。 1.PHP適合web開發，語法簡單，執行效率高。 2.Python適用於數據科學和機器學習，語法簡潔，庫豐富。
創造未來：零基礎的 Java 編程
Oct 13, 2024 pm 01:32 PM
Java是熱門程式語言，適合初學者和經驗豐富的開發者學習。本教學從基礎概念出發，逐步深入解說進階主題。安裝Java開發工具包後，可透過建立簡單的「Hello,World!」程式來實踐程式設計。理解程式碼後，使用命令提示字元編譯並執行程序，控制台上將輸出「Hello,World!」。學習Java開啟了程式設計之旅，隨著掌握程度加深，可創建更複雜的應用程式。
