1. 程式人生 > 其它 >在java中實現Mysql的增刪改查

在java中實現Mysql的增刪改查

技術標籤:JDBCmysql

【整體思路】在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;
}
  1. sql為初始的sql查詢語句select code,name,birthday,gender,entry_time,tel from employee where 1=1,定義為StringBuffer型別可以方便地用append()方法追加查詢條件;
  2. 此時的實體類物件包含的屬性全部是查詢條件組成,下邊的判空就是找到查詢條件並追加在sql語句上;
  3. 此方法的返回值是查詢條件的集合,用此集合可以方便地對預處理狀態集進行賦值,並且因為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;
}
  1. sql語句的1=1保證了查詢條件為空時也能正確執行sql語句,為恆真;
  2. 將結果集新增到要返回的集合中。

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]

在這裡插入圖片描述