通過(guò)代理類實(shí)現(xiàn)java連接數(shù)據(jù)庫(kù)(使用dao層操作數(shù)據(jù))實(shí)例分享
首先，我們?cè)谝粋€(gè)java文件中定義要存儲(chǔ)的結(jié)構(gòu)類型：
import java.util.Date ;
/**
*
* @author Nero
*/
public class Emp {
private int empno ;
private String ename ;
private String job ;
private Date hiredate ;
private float sal ;
public void setEmpno(int empno){
this.empno = empno ;
}
public void setEname(String ename){
this.ename = ename ;
}
public void setJob(String job){
this.job = job ;
}
public void setHiredate(Date hiredate){
this.hiredate = hiredate ;
}
public void setSal(float sal){
this.sal = sal ;
}
public int getEmpno(){
return this.empno ;
}
public String getEname(){
return this.ename ;
}
public String getJob(){
return this.job ;
}
public Date getHiredate(){
return this.hiredate ;
}
public float getSal(){
return this.sal ;
}
}
下面我們定義一個(gè)數(shù)據(jù)庫(kù)連接類，負(fù)責(zé)向數(shù)據(jù)庫(kù)發(fā)起連接。java連接數(shù)據(jù)庫(kù)需要驅(qū)動(dòng)包，我們可以自行下載，測(cè)試的時(shí)候我使用的是mysql-connector-java-5.0.5-bin.jar。在運(yùn)行程序的時(shí)候Eclipse會(huì)提示需要加載的數(shù)據(jù)庫(kù)驅(qū)動(dòng)包，一些是類似于"org.gjt.mm.mysql.Driver" 之類的標(biāo)準(zhǔn)包，一般來(lái)說(shuō)我們選擇工作目錄里的驅(qū)動(dòng)包就可以了。
import java.sql.Connection ;
import java.sql.DriverManager ;
/**
*
* @author Nero
*/
public class DatabaseConnection {
private static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
private static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
private static final String DBUSER = "root" ;
private static final String DBPASSWORD = "root" ;
private Connection conn ;
public DatabaseConnection() throws Exception {
Class.forName(DBDRIVER) ;
this.conn = DriverManager.getConnection(DBURL,DBUSER,DBPASSWORD) ;
}
public Connection getConnection(){
return this.conn ;
}
public void close() throws Exception {
if(this.conn != null){
try{
this.conn.close() ;
}catch(Exception e){
throw e ;
}
}
}
}
接下來(lái)我們定義一個(gè)接口，這個(gè)接口能夠幫助我們輕松地實(shí)現(xiàn)代理方法。接口內(nèi)的方法只有三個(gè)：插入、查找全部和通過(guò)ID查找。
import java.util.* ;
/**
*
* @author Nero
*/
public interface IEmpDAO {
public boolean doCreate(Emp emp) throws Exception ;
public List<Emp> findAll(String keyWord) throws Exception ;
public Emp findById(int empno) throws Exception ;
}
然后呢，我們繼承這個(gè)接口，實(shí)現(xiàn)具體數(shù)據(jù)庫(kù)的操作類，都是一些很基本的數(shù)據(jù)庫(kù)操作，沒(méi)啥好說(shuō)的。主要要注意的是構(gòu)造函數(shù)那里，參數(shù)使用Connection對(duì)象，后面使用這個(gè)類的時(shí)候要傳入前面定義的數(shù)據(jù)庫(kù)連接類DatabaseConnection中的函數(shù)getConnection()返回的Connection對(duì)象。
import java.sql.* ;
/**
*
* @author Nero
*/
public class EmpDAOImpl implements IEmpDAO{
private Connection conn = null ;
private PreparedStatement pstmt = null ;
public EmpDAOImpl(Connection conn)
{
this.conn = conn;
}
public boolean doCreate(Emp emp) throws Exception{
boolean flag = false;
String sql = "INSERT INTO emp(empno,ename,job,hiredate,sal) VALUES(?,?,?,?,?)";
this.pstmt = this.conn.prepareStatement(sql);
this.pstmt.setInt(1, emp.getEmpno());
this.pstmt.setString(2,emp.getEname()) ;
this.pstmt.setString(3,emp.getJob()) ;
this.pstmt.setDate(4,new java.sql.Date(emp.getHiredate().getTime())) ;
this.pstmt.setFloat(5,emp.getSal()) ;
if(this.pstmt.executeUpdate() > 0)
{
flag = true;
}
this.pstmt.close();
return flag;
}
public List<Emp> findAll(String keyWord) throws Exception{
List<Emp> all = new ArrayList<Emp>();
String sql = "SELECT empno,ename,job,hiredate,sal FROM emp WHERE ename LIKE ? OR job LIKE ?";
this.pstmt = this.conn.prepareStatement(sql);
this.pstmt.setString(1,"%"+keyWord+"%"); //轉(zhuǎn)義字符
this.pstmt.setString(2,"%"+keyWord+"%");
ResultSet rs = this.pstmt.executeQuery(sql);
Emp emp = null;
while(rs.next())
{
emp = new Emp();
emp.setEmpno(rs.getInt(1));
emp.setEname(rs.getString(2)) ;
emp.setJob(rs.getString(3)) ;
emp.setHiredate(rs.getDate(4)) ;
emp.setSal(rs.getFloat(5)) ;
all.add(emp);
}
this.pstmt.close();
return all;
}
public Emp findById(int empno) throws Exception{
Emp emp = null ;
String sql = "SELECT empno,ename,job,hiredate,sal FROM emp WHERE empno=?" ;
this.pstmt = this.conn.prepareStatement(sql) ;
this.pstmt.setInt(1,empno) ;
ResultSet rs = this.pstmt.executeQuery() ;
if(rs.next()){
emp = new Emp() ;
emp.setEmpno(rs.getInt(1)) ;
emp.setEname(rs.getString(2)) ;
emp.setJob(rs.getString(3)) ;
emp.setHiredate(rs.getDate(4)) ;
emp.setSal(rs.getFloat(5)) ;
}
this.pstmt.close() ;
return emp ;
}
}
下面我們看看代理類的實(shí)現(xiàn)，個(gè)人覺(jué)得到這里就比較有意思了。在這個(gè)類里面，聲明了一個(gè)數(shù)據(jù)庫(kù)連接類DatabaseConnection的對(duì)象，一個(gè)數(shù)據(jù)庫(kù)應(yīng)用類EmpDAOImpl對(duì)象，用DatabaseConnection對(duì)象初始化EmpDAOImpl對(duì)象，然后在代理類的每個(gè)函數(shù)中都使用EmpDAOImpl對(duì)象去調(diào)用從同一接口繼承而來(lái)的方法，這樣即對(duì)具體實(shí)現(xiàn)方法進(jìn)行了一定程度的隱藏。
import java.sql.* ;
/**
*
* @author Nero
*/
public class EmpDAOProxy implements IEmpDAO{
private DatabaseConnection dbc = null ;
private EmpDAOImpl dao = null ;
public EmpDAOProxy() throws Exception{
this.dbc = new DatabaseConnection();
this.dao = new EmpDAOImpl(this.dbc.getConnection());
}
public boolean doCreate(Emp emp) throws Exception{
boolean flag = false;
try{
if(this.dao.findById(emp.getEmpno()) == null)
{
flag = this.dao.doCreate(emp);
}
}catch(Exception e)
{
throw e;
}finally{
this.dbc.close();
}
return flag;
}
public List<Emp> findAll(String keyWord) throws Exception{
List<Emp> all = null ;
try{
all = this.dao.findAll(keyWord) ;
}catch(Exception e){
throw e ;
}finally{
this.dbc.close() ;
}
return all ;
}
public Emp findById(int empno) throws Exception{
Emp emp = null ;
try{
emp = this.dao.findById(empno) ;
}catch(Exception e){
throw e ;
}finally{
this.dbc.close() ;
}
return emp ;
}
}
這還不是全部，我們可以再加一個(gè)工廠類來(lái)實(shí)現(xiàn)工廠模式：
/**
*
* @author Nero
*/
public class DAOFactory {
public static IEmpDAO getIEmpDAOInstance() throws Exception{
return new EmpDAOProxy() ;
}
}
這個(gè)工廠類有什么用呢？最后我們?cè)谥黝愇募羞M(jìn)行調(diào)用，可以看看工廠類有什么作用：
/**
*
* @author Nero
*/
public class TestDAOInsert {
public static void main(String args[]) throws Exception{
Emp emp = null ;
for(int x=0;x<5;x++){
emp = new Emp() ;
emp.setEmpno(1000 + x) ;
emp.setEname("中文顯示測(cè)試 - " + x) ;
emp.setJob("程序員 - " + x) ;
emp.setHiredate(new java.util.Date()) ;
emp.setSal(500 * x) ;
DAOFactory.getIEmpDAOInstance().doCreate(emp) ;
}
}
}
可見(jiàn)具體的實(shí)現(xiàn)方法隱藏得比較好，通過(guò)工廠類調(diào)用get方法獲取代理類，代理類調(diào)用特定方法，然后由代理類內(nèi)的具體操作對(duì)象去調(diào)用具體的操作方法。
其實(shí)這些東西看起來(lái)會(huì)覺(jué)得很簡(jiǎn)單，但是自己設(shè)計(jì)的時(shí)候往往會(huì)忘記。主要是因?yàn)橛玫貌欢喟?，一開(kāi)始總是要強(qiáng)迫自己想起來(lái)去做，然后慢慢地才能變成一種習(xí)慣。
相關(guān)文章
這篇文章主要介紹了Java多線程Condition接口原理介紹，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-09-09
Spring中@Scheduled和HttpClient的連環(huán)坑
這篇文章主要給大家介紹了關(guān)于Spring中@Scheduled和HttpClient的連環(huán)坑，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧。2018-03-03
SpringBoot整合MongoDB的實(shí)現(xiàn)代碼
自己本科時(shí)候一直使用的是Mysql，目前的課題組使用的是MongoDB，因此就花了一部分時(shí)間整理了一下，實(shí)現(xiàn)springboot與MongoDB的整合，并且實(shí)現(xiàn)基本的增刪改查操作，從頭到尾給出一個(gè)完整的案例。2021-05-05
本文給大家匯總介紹了下使用java實(shí)現(xiàn)獲取客戶端用戶的MAC地址的方法，當(dāng)然最后一種更全面一些，有需要的小伙伴們可以根據(jù)需求自由選擇。2015-10-10
使用Java通過(guò)OAuth協(xié)議驗(yàn)證發(fā)送微博的教程
這篇文章主要介紹了使用Java通過(guò)OAuth協(xié)議驗(yàn)證發(fā)送微博的教程,使用到了新浪微博為Java開(kāi)放的API weibo4j,需要的朋友可以參考下2016-02-02
Springboot遵循“約定優(yōu)于配置”的原則,使用注解對(duì)一些常規(guī)的配置項(xiàng)做默認(rèn)配置,減少或不使用xml配置,讓你的項(xiàng)目快速運(yùn)行起來(lái),這篇文章主要給大家介紹了關(guān)于Springboot自動(dòng)加載配置原理的相關(guān)資料,需要的朋友可以參考下2021-10-10
這篇文章主要介紹了Java獲取UTC時(shí)間的方法,結(jié)合具體實(shí)例形式詳細(xì)分析了Java針對(duì)時(shí)區(qū)、本地時(shí)間、時(shí)間偏移量等相關(guān)操作技巧,需要的朋友可以參考下2017-04-04
java中實(shí)現(xiàn)map與對(duì)象相互轉(zhuǎn)換的幾種實(shí)現(xiàn)
這篇文章主要介紹了java中實(shí)現(xiàn)map與對(duì)象相互轉(zhuǎn)換的幾種實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
Java的Scanner用法,主要用于算法筆試時(shí)的控制臺(tái)輸入,下面這篇文章主要給大家介紹了關(guān)于java中Scanner輸入用法的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-09-09
Spring boot實(shí)現(xiàn)一個(gè)簡(jiǎn)單的ioc（1）
這篇文章主要為大家詳細(xì)介紹了Spring boot實(shí)現(xiàn)一個(gè)簡(jiǎn)單的ioc，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-04-04