電子發燒友App
用JDBC連接MySQL數據庫并進行簡單的增刪改查操作
簡單的JDBC實例
現在使用JDBC寫一個簡單的小程序，主要是使用JDBC連接MySQL數據庫，然后對數據庫進行一些基本的增刪改查操作。
1、設計數據庫表
先設計一個數據庫表，用于保存用戶信息，建表語句如下：
CREATE TABLE
tbl_user_info
（
id INT NOT NULL AUTO_INCREMENT，
user_name VARCHAR（20） NOT NULL，
age INT NOT NULL，
sex INT（1） NOT NULL，
create_dt DATE NOT NULL，
PRIMARY KEY （id）
）
ENGINE=InnoDB DEFAULT CHARSET=utf8;
在用戶表中定義了幾個字段，分別是id，user_name，age，sex，create_dt，其中id是主鍵，是自增長的，user_name表示用戶名，age表示用戶年齡，sex表示用戶的性別，這里的性別用數字表示，0表示女性，1表示男性，create_dt表示創建的時間。預先在數據庫中插入幾條數據，數據如下。
?
2、定義實體類
定義一個Bean，與數據庫表中的各個字段對應：
package com.imooc.jdbc;
public class UserVO {
private int id;
private String userName;
private int age;
private int sex;
private Date createDt;
public int getId（） {
return id;
}
public void setId（int id） {
this.id = id;
}
public String getUserName（） {
return userName;
}
public void setUserName（String userName） {
this.userName = userName;
}
public int getAge（） {
return age;
}
public void setAge（int age） {
this.age = age;
}
public int getSex（） {
return sex;
}
public void setSex（int sex） {
this.sex = sex;
}
public Date getCreateDt（） {
return createDt;
}
public void setCreateDt（Date createDt） {
this.createDt = createDt;
}
@Override
public String toString（） {
return “UserVO ［id=” + id + “， userName=” + userName + “， age=” + age
+ “， sex=” + sex + “， createDt=” + createDt + “］”;
}
}
3、定義數據庫連接類
定義一個數據庫連接類，用于獲取MySQL的連接
package com.imooc.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
public class DBUtil {
private static final String URI = “jdbc:mysql://192.168.2.207:3306/jdbc_demo？”
+ “user=root&password=root&useUnicode=true&characterEncoding=UTF-8”;
private static final String DRIVER = “com.mysql.jdbc.Driver”;
public static Connection connectDB（） throws Exception {
//1、加載數據庫驅動
Class.forName（DRIVER）;
//2、獲取數據庫連接
Connection conn = DriverManager.getConnection（URI）;
return conn;
}
}
MySQL的JDBC URL編寫方式為：jdbc:mysql://主機名稱：連接端口/數據庫的名稱？參數=值，在這個例子中我連接的數據庫主機是一臺遠程主機，所以主機名稱為遠程主機的ip地址，如果數據庫主機為本機，則可以定義為localhost，在參數中指定用戶名為root，密碼也是root，為了避免中文亂碼要指定useUnicode和characterEncoding。因為連接的是MySQL數據庫，所以程序一開始需要加載MySQL的數據庫驅動，然后通過DriverManager.getConnection（String URL）方法獲取數據庫的連接。
4、實現數據庫的增刪改查
在獲取了數據庫的連接之后，就可以操作數據庫了，下面分別實現數據庫的增刪改查操作，定義一個UserDao類用于操作數據庫。
1）查詢
先看查詢操作，查詢可以一次查詢出所有的數據，也可以根據相應的條件查詢。
查詢所有的數據，在UserDao中定義一個queryAll（）方法：
public List
Connection conn = DBUtil.connectDB（）;
String sql = “SELECT * FROM tbl_user_info”;
List
Statement stmt = conn.createStatement（）;
ResultSet rs = stmt.executeQuery（sql）;
while（rs.next（）） {
UserVO user = new UserVO（）;
user.setId（rs.getInt（“id”））;
user.setUserName（rs.getString（“user_name”））;
user.setAge（rs.getInt（“age”））;
user.setSex（rs.getInt（“sex”））;
user.setCreateDt（rs.getDate（“create_dt”））;
userList.add（user）;
}
return userList;
}
這里使用Connection.createStatement（）方法獲取一個Statement對象，這個對象里面有很多的方法可以操作數據庫，使用excuteQuery（String sql）執行查詢操作，查詢結果為一個結果集ResultSet，可以通過這個結果集獲取相關的信息。
定義main函數：
public static void main（String［］ args） {
UserDao dao = new UserDao（）;
try {
List
for（UserVO user ： userList） {
System.out.println（user）;
}
} catch （Exception e） {
e.printStackTrace（）;
}
}
執行結果：
UserVO ［id=4， userName=Mary， age=25， sex=0， createDt=2016-06-24］
UserVO ［id=5， userName=Jack， age=22， sex=1， createDt=2016-06-24］
UserVO ［id=6， userName=John， age=19， sex=1， createDt=2016-06-24］
根據條件查詢，定義一個queryByParams方法：
public List
Connection conn = DBUtil.connectDB（）;
StringBuilder sql = new StringBuilder（“SELECT * FROM tbl_user_info WHERE 1=1 ”）;
for（Map
sql.append（“ and ”）;
sql.append（“ ” + param.get（“col”） + “ ”）;
sql.append（“ ” + param.get（“rel”） + “ ”）;
sql.append（“ ” + param.get（“value”） + “ ”）;
}
System.out.println（sql.toString（））;
List
Statement stmt = conn.createStatement（）;
ResultSet rs = stmt.executeQuery（sql.toString（））;
while（rs.next（）） {
UserVO user = new UserVO（）;
user.setId（rs.getInt（“id”））;
user.setUserName（rs.getString（“user_name”））;
user.setAge（rs.getInt（“age”））;
user.setSex（rs.getInt（“sex”））;
user.setCreateDt（rs.getDate（“create_dt”））;
userList.add（user）;
}
return userList;
}
這個方法可以自由選擇查詢的條件，只需要向方法中傳入一個條件的List即可，這些條件都是由Map組成的，每一個Map包含三個元素，col表示查詢條件對應哪一列，rel表示查詢條件的關系是什么，value是指查詢條件的值。這樣寫集成了多查詢條件的方法，很多的業務下，查詢的邏輯可能很多，這樣寫只用一個統一的方法就可以解決多種不同查詢條件的業務邏輯。
再寫一個簡單的main函數測試一下：
public static void main（String［］ args） {
UserDao dao = new UserDao（）;
List
Map
param1.put（“col”， “user_name”）;
param1.put（“rel”， “like”）;
param1.put（“value”， “‘%John%’”）;
params.add（param1）;
Map
param2.put（“col”， “sex”）;
param2.put（“rel”， “=”）;
param2.put（“value”， 1）;
params.add（param2）;
try {
List
for（UserVO user ： userList） {
System.out.println（user）;
}
} catch （Exception e） {
e.printStackTrace（）;
}
}
在這個main方法中設定了兩個查詢條件，一是user_name like %John%，另一個是sex=1，當然條件也可以是其他的，執行程序運行結果為：
SELECT * FROM tbl_user_info WHERE 1=1 and user_name like ‘%John%’ and sex = 1
UserVO ［id=6， userName=John， age=19， sex=1， createDt=2016-06-24］
2）增加
現在在UserDao中寫一個addUser方法用于新增一條信息：
public void addUser（UserVO user） throws Exception {
Connection conn = DBUtil.connectDB（）;
String sql = “INSERT INTO tbl_user_info（user_name， age， sex， create_dt） ”
+ “ VALUES（？， ？， ？， ？）”;
PreparedStatement pstmt = conn.prepareStatement（sql）;
pstmt.setString（1， user.getUserName（））;
pstmt.setInt（2， user.getAge（））;
pstmt.setInt（3， user.getSex（））;
pstmt.setDate（4， new Date（new java.util.Date（）.getTime（）））;
pstmt.execute（）;
}
這個方法使用Connection.prepareStatement（String sql）方法獲取一個PreparedStatement對象，使用這個方法可以傳入帶參數的SQL語句，而參數的值可以通過PreparedStatement.setXXX（int index， XXX value）的方法指定，其中XXX為各種不同的類型，index指定第幾個參數的下標。指定了參數的值之后，便可以執行excute（）方法執行SQL語句了。
接下來寫一個main方法來驗證這個增加的方法：
public static void main（String［］ args） {
UserDao dao = new UserDao（）;
UserVO user = new UserVO（）;
user.setUserName（“Tom”）;
user.setAge（20）;
user.setSex（1）;
try {
dao.addUser（user）;
} catch （Exception e） {
e.printStackTrace（）;
}
}
執行后再查看數據庫，發現Tom這個用戶已經插入成功了。
?
3）刪除
接下來再寫一個刪除的方法，根據用戶的id來刪除數據：
public void deleteUser（int id） throws Exception {
Connection conn = DBUtil.connectDB（）;
String sql = “DELETE FROM tbl_user_info WHERE id = ？”;
PreparedStatement pstmt = conn.prepareStatement（sql）;
pstmt.setInt（1， id）;
pstmt.execute（）;
}
然后寫一個main方法來驗證：
public static void main（String［］ args） {
UserDao dao = new UserDao（）;
try {
dao.deleteUser（7）;
} catch （Exception e） {
e.printStackTrace（）;
}
}
刪除id為7的用戶，也就是剛剛用新增方法創建的用戶名為Tom的這個用戶，運行后查看數據庫：
?
4）更新數據庫
最后來看一下更新數據庫：
public void updateUser（UserVO user） throws Exception {
Connection conn = DBUtil.connectDB（）;
String sql = “UPDATE tbl_user_info SET user_name=？， age=？， sex=？”
+ “ WHERE id=？”;
PreparedStatement pstmt = conn.prepareStatement（sql）;
pstmt.setString（1， user.getUserName（））;
pstmt.setInt（2， user.getAge（））;
pstmt.setInt（3， user.getSex（））;
pstmt.setInt（4， user.getId（））;
pstmt.executeUpdate（）;
}
從SQL語句中可以看出更新也是根據用戶的id進行選擇性的更新的。
寫一個main方法來驗證：
public static void main（String［］ args） {
UserDao dao = new UserDao（）;
UserVO user = new UserVO（）;
user.setUserName（“Mary”）;
user.setAge（30）;
user.setSex（0）;
user.setId（4）;
try {
dao.updateUser（user）;
} catch （Exception e） {
e.printStackTrace（）;
}
}
這個方法里將用戶名為Mary的用戶年齡改為30歲，執行程序，運行后查看數據庫：
?
可以看到Mary的年齡確實變成了30，，刪除成功。
三、結語
由此使用JDBC連接MySQL數據庫并進行基本的增刪改查操作就已經完成了，這些只是最簡單的數據庫操作，實際開發過程中操作數據庫比這些要復雜得多，包括事務的處理、存儲過程等等，那就需要使用JDBC更高級的功能了，這些下次再寫。
工商網監
評論