在java中實現Mysql的增刪改查
阿新 • • 發佈:2021-01-19
【整體思路】在java包中建立一個Dao類(資料類),通過建立方法實現對實體類物件的操作
文章目錄
一、實體類展示
package JDBCConnectJava;
import java.sql.Date;
public class EmployeeModel {
private String code; // 員工號
private String name; // 員工姓名
private String gender; // 性別
private String birthday; // 出生日期
private Date entryDate; // 入職時間
private String tel; // 電話
public EmployeeModel(String code, String name, String gender, String birthday, Date entryDate, String tel) {
super();
this.code = code;
this.name = name;
this.gender = gender;
this.birthday = birthday;
this.entryDate = entryDate;
this.tel = tel;
}
public EmployeeModel(String code) {
super();
this.code = code;
}
public EmployeeModel() {
super();
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getGendar() {
return gender;
}
public void setGendar(String gendar) {
this.gender = gendar;
}
public String getBirthday() {
return birthday;
}
public void setBirthday(String birthday) {
this.birthday = birthday;
}
public Date getEntryDate() {
return entryDate;
}
public void setEntryDate(Date entryDate) {
this.entryDate = entryDate;
}
public String getTel() {
return tel;
}
public void setTel(String tel) {
this.tel = tel;
}
@Override
public String toString() {
return "員工資訊[員工號:" + code + ", 姓名:" + name + ", 性別:" + gender + ", 出生日期:" + birthday + ", 入職時間:" + entryDate
+ ", 電話:" + tel + "]";
}
}
一個簡單的employee實體類~
二、JDBCutil工具類的展示
package JDBCConnectJava;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ResourceBundle;
public class JDBCutil {
static ResourceBundle re = ResourceBundle.getBundle("package1.jdbc");
static String driver = re.getString("driver");
static String url = re.getString("url");
static String user = re.getString("user");
static String pass = re.getString("pass");
// 私有的構造 防止外邊建立物件
private JDBCutil() {
}
// 每次使用類時,自動載入驅動
static {
try {
Class.forName(driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
// 獲取連線
public static Connection getConnection() {
try {
return DriverManager.getConnection(url, user, pass);
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
// 關閉--1
public static void close(Connection con, Statement st) {
try {
st.close();
st = null;
con.close();
con = null;
} catch (SQLException e) {
e.printStackTrace();
}
}
// 關閉--2
public static void close(Connection con, Statement st, ResultSet re) {
try {
st.close();
st = null;
con.close();
con = null;
re.close();
re = null;
} catch (SQLException e) {
e.printStackTrace();
}
}
}
在JDBC模組的最後有過對工具類簡單介紹。這裡可以把工具類應用到具體程式碼中。
三、Dao類展示
3.1 資料庫初始資料
3.1 增加
// 新增資料
public Integer intsert(EmployeeModel em) {
String sql = "insert into employee(code,name,gender,birthday,entry_time,tel) values(?,?,?,?,?,?)";
Connection con = null;
PreparedStatement st = null;
Integer result = null;//返回值
con = JDBCutil.getConnection();
try {
st = con.prepareStatement(sql);
st.setString(1, em.getCode());
st.setString(2, em.getName());
st.setString(3, em.getGendar());
st.setString(4, em.getBirthday());
st.setDate(5, em.getEntryDate());
st.setString(6, em.getTel());
result = st.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
JDBCutil.close(con, st);
}
return result;
}
main方法:
public static void main(String[] args) {
IEmployeeDao dao = new IEmployeeDao();
// 1--新增
EmployeeModel em = new EmployeeModel("05","劉曉開","男","1997-05-21",Date.valueOf(LocalDate.now()),"15223656987");
if(dao.intsert(em)==null)
{
System.out.println("新增失敗!");
}else {
System.out.println("新增成功!");
}
}
執行結果:
新增成功!
執行後的表資料:
可以看到05號已被新增入表中。
連線的關鍵主要就是從物件em中獲得要新增的資料。
3.2 刪除
// 刪除資料
public Integer delete(EmployeeModel em) {
String sql = "delete from employee where code = ?";
Connection con = JDBCutil.getConnection();
PreparedStatement st = null;
Integer result = null;
try {
st = con.prepareStatement(sql);
st.setString(1, em.getCode());
result = st.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
JDBCutil.close(con, st);
}
return result;
}
main方法:
public static void main(String[] args) {
IEmployeeDao dao = new IEmployeeDao();
//2--刪除
EmployeeModel em = new EmployeeModel("01");
if(dao.delete(em)==null)
{
System.out.println("刪除失敗!");
}else {
System.out.println("刪除成功!");
}
}
結果:
刪除成功!
這是資料庫的01號已被刪除:
3.3 修改
// 修改資料
public Integer update(EmployeeModel em) {
String sql = "update employee set name = ?,gender = ?,birthday = ?,entry_time = ?,tel = ?where code = ?";
Connection con = JDBCutil.getConnection();
PreparedStatement st = null;
Integer result = null;
try {
st = con.prepareStatement(sql);
st.setString(1, em.getName());
st.setString(2, em.getGendar());
st.setString(3, em.getBirthday());
st.setDate(4, em.getEntryDate());
st.setString(5, em.getTel());
st.setString(6, em.getCode());
result = st.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
JDBCutil.close(con, st);
}
return result;
}
main中執行:
public static void main(String[] args) {
IEmployeeDao dao = new IEmployeeDao();
//3--修改
EmployeeModel em = new EmployeeModel("02", "李曉美", "女", "1999-05-21", Date.valueOf(LocalDate.now()),"15562599863");
if (dao.update(em) == null) {
System.out.println("修改失敗!");
} else {
System.out.println("修改成功!");
}
}
執行結果:
修改成功!
此時的資料庫資料已修改:
3.4 查詢
【查詢要考慮的問題是查詢條件的不確定性,那麼如何解決這個問題呢?】
【我們可以先定義一個方法,把查詢的條件即where後邊的內容確定下來:】
// 新增查詢條件
private ArrayList<Object> addWhere(StringBuffer sql, EmployeeModel em) {
ArrayList<Object> ob = new ArrayList<Object>();
String name = em.getName();
if (name != null && !name.trim().isEmpty()) {
sql.append("and name like ? ");
ob.add(name);
}
String code = em.getCode();
if (code != null && !code.trim().isEmpty()) {
sql.append("and code like ? ");
ob.add(code);
}
String gender = em.getGendar();
if (gender != null && !gender.trim().isEmpty()) {
sql.append("and gender like ? ");
ob.add(gender);
}
return ob;
}
- sql為初始的sql查詢語句
select code,name,birthday,gender,entry_time,tel from employee where 1=1
,定義為StringBuffer型別可以方便地用append()方法追加查詢條件; - 此時的實體類物件包含的屬性全部是查詢條件組成,下邊的判空就是找到查詢條件並追加在sql語句上;
- 此方法的返回值是查詢條件的集合,用此集合可以方便地對預處理狀態集進行賦值,並且因為ArrayList的順序性,可以使set方法找到對應的佔位符的位置。
【確定好查詢條件後,剩下的查詢就好做了:】
// 查詢資料
public ArrayList<EmployeeModel> select(EmployeeModel em) {
StringBuffer sql = new StringBuffer("select code,name,birthday,gender,entry_time,tel from employee where 1=1 ");
ArrayList<Object> arr = addWhere(sql,em);
Connection con = JDBCutil.getConnection();
PreparedStatement st = null;
ResultSet re = null;
ArrayList<EmployeeModel> list = new ArrayList<EmployeeModel>();
try {
st = con.prepareStatement(sql.toString());
//佔位符賦值
for(int i=0;i<arr.size();i++) {
st.setObject(i+1, arr.get(i));
}
re = st.executeQuery();
//將結果集新增到要返回的集合中
while(re.next()) {
EmployeeModel e = new EmployeeModel();
e.setCode(re.getString("code"));
e.setName(re.getString("name"));
e.setGendar(re.getString("gender"));
e.setBirthday(re.getString("birthday"));
e.setEntryDate(re.getDate("entry_time"));
e.setTel(re.getString("tel"));
list.add(e);
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
JDBCutil.close(con, st, re);
}
return list;
}
- sql語句的
1=1
保證了查詢條件為空時也能正確執行sql語句,為恆真; - 將結果集新增到要返回的集合中。
main方法的執行:
public static void main(String[] args) {
IEmployeeDao dao = new IEmployeeDao();
//4--查詢
EmployeeModel em = new EmployeeModel();
em.setName("王%");
ArrayList<EmployeeModel> arr = dao.select(em);
for(EmployeeModel e:arr) {
System.out.println(e.toString());
}
}
執行結果:
員工資訊[員工號:03, 姓名:王五, 性別:男, 出生日期:2000-07-15, 入職時間:2015-07-08, 電話:17866639856]
員工資訊[員工號:04, 姓名:王歐凱, 性別:男, 出生日期:2000-07-10, 入職時間:2015-07-08, 電話:17889653216]