DAO開發

ＤAO開發完全圍繞著數據操作進行。

（1）下面按照DAO的方式完成后端代碼的開發，首行定義VO類，VO類的名稱與表的名稱一致，但是要注意類的命名的規范－－－單詞首字母大寫。

package com.test.vo;import java.util.Date;/*** VO類，VO類的名稱與數據庫中表的名稱一致，* 且類中各屬性與表中各字段一一對應* */ public class GPSLOG {//屬性private String licenseplateno ;private Date in_date;private Date gps_time;private String longitude;private String latitude ;private String height ;private String speed ;private String direction;private String eff ;private String car_stat1;private String car_stat2;//getters and setterspublic String getLicenseplateno() {return licenseplateno;}public void setLicenseplateno(String licenseplateno) {this.licenseplateno = licenseplateno;}public Date getIn_date() {return in_date;}public void setIn_date(Date in_date) {this.in_date = in_date;}public Date getGps_time() {return gps_time;}public void setGps_time(Date gps_time) {this.gps_time = gps_time;}public String getLongitude() {return longitude;}public void setLongitude(String longitude) {this.longitude = longitude;}public String getLatitude() {return latitude;}public void setLatitude(String latitude) {this.latitude = latitude;}public String getHeight() {return height;}public void setHeight(String height) {this.height = height;}public String getSpeed() {return speed;}public void setSpeed(String speed) {this.speed = speed;}public String getDirection() {return direction;}public void setDirection(String direction) {this.direction = direction;}public String getEff() {return eff;}public void setEff(String eff) {this.eff = eff;}public String getCar_stat1() {return car_stat1;}public void setCar_stat1(String car_stat1) {this.car_stat1 = car_stat1;}public String getCar_stat2() {return car_stat2;}public void setCar_stat2(String car_stat2) {this.car_stat2 = car_stat2;} } 本程序只是一個簡單的VO類，包含了屬性、getter、setter方法。特別要注意的是，其中表示日期時使用的是java.util.Date類。

（2）定義完VO類后，下面定義一個數據庫連接類，此類完成數據庫的打開及關閉操作。

1》在DAO操作中，由于要適應不同的數據庫，所以會將所有可能變化的地方都通過接口進行實現。例如，一個DAO操作類既可以在Oracle下使用，也可以在MySQL下使用，往往會將其定義成一個接口:

package com.test.jdbc;import java.sql.Connection; /*** 定義數據庫連接接口，以適用不同的數據庫連接，如Oracle，或者MySQL數據庫* */ public interface IDBConnection {//定義DatabaseConnection接口//取得數據庫連接public Connection getConnection();//關閉數據庫連接public void close(); }
2》然后根據不同的數據庫定義不同的子類，例如以下是Oracle數據庫連接的代碼實現：

package com.test.jdbc;import java.sql.Connection; import java.sql.DriverManager;import com.test.jdbc.IDBConnection; /*** 取得Oracle數據庫連接* */ public class OracleDBConnection implements IDBConnection {//DB Driverprivate static final String DBDRIVER="oracle.jdbc.driver.OracleDriver";//DB URLprivate static final String DBURL="jdbc:oracle:thin:@192.168.95.86:1521:orcl"; //DB Userprivate static final String DBUSER="xxtmanage";//DB Passwordprivate static final String DBPASSWORLD="xxtinterface";//DB Connectionprivate Connection conn=null;//structorpublic OracleDBConnection() {//在構造方法中進行數據庫連接System.out.println("OracleDBConnection.OracleDBConnection()");try {// 加載驅動程序Class.forName(DBDRIVER);//連接數據庫this.conn=DriverManager.getConnection(DBURL, DBUSER, DBPASSWORLD);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}@Overridepublic Connection getConnection(){System.out.println("OracleDBConnection.getConnection()");return this.conn;}@Overridepublic void close(){System.out.println("OracleDBConnection.close()");if(this.conn!=null){try {this.conn.close();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}
3》以下是MySQL的數據庫連接代碼（具體代碼未實現）:

package com.test.jdbc;import java.sql.Connection;import com.test.jdbc.IDBConnection; /*** 取得MySQL數據庫連接* */ public class MySQLDBConnection implements IDBConnection {@Overridepublic Connection getConnection() {// TODO Auto-generated method stubreturn null;}@Overridepublic void close() {// TODO Auto-generated method stub}} 4》此時，如果要想取得一個IDBConnection接口的連接對象，還需要一個工廠類完成。

package com.test.jdbc; /*** 數據庫連接工廠類，* 根據現有數據庫，取得相應數據庫連接。* */ public class DBConnectionFactory {public static IDBConnection getDBConnection(){//根據所使用的數據庫，返回相應的數據庫連接。//返回Oracle數據庫連接System.out.println("DBConnectionFactory.getDBConnection()");return new OracleDBConnection();/*** 返回MySQL數據庫連接* return new MySQLDBConnection();* */}}
通過以上代碼可以減少類之間的耦合度。

（3）在DAO設計模式中，最重要的就是定義DAO接口，在定義DAO接口之前必須對業務時行詳細的分析，要清楚地知道一張表在整個系統中應該具備何種功能。

本程序只完成數據庫的增加功能 ，其他功能可以按照建好的架構進行增加。

1》定義DAO操作標準---IGpsDao.java

package com.test.dao;import com.test.vo.GPSLOG; /*** 定義DAO操作標準* */ public interface IGpsDao {/*** 數據的增加操作* @param gpslog 要增加的數據對象--GPS日志信息* @return 是否增加成功的標記* @throws 有異常交給調用者處理* */public boolean insertLog(GPSLOG gpslog)throws Exception;/*** 建表* */public void createTab() throws Exception ;}

在DAO的操作標準中定義了 insertLog(GPSLOG gpslog),和createTab()2個功能 。

2》DAO接口定義完成后需要做具體的實現類，但是這里DAO的實現類有兩種，一種是真實主題類，另外一種是代理操作類。

真實主題類主要負責具體的數據庫操作，在操作時為了性能及安全將使用PreparedStatement接口完成。

package com.test.dao;import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException;import com.test.dao.IGpsDao; import com.test.vo.GPSLOG; /*** 真實主題實現類* */ public class GpsLogDAOImpl implements IGpsDao {//數據庫連接對象private Connection conn=null;//數據庫操作對象private PreparedStatement pstmt=null;public GpsLogDAOImpl(Connection conn){//通過構造方法取得數據庫連接System.out.println("GpsLogDAOImpl.GpsLogDAOImpl()");this.conn=conn;}@Overridepublic boolean insertLog(GPSLOG gpslog) throws Exception {// TODO Auto-generated method stubSystem.out.println("GpsLogDAOImpl.doCreate()");boolean flag=false;String sql="INSERT INTO GPS_LOG_cxc "+ "(licenseplateno ,in_date,gps_time,longitude,latitude,height,speed, direction , eff, car_stat1, car_stat2)"+"VALUES(?,?,?,?,?,?,?,?,?,?,?)";//實例化PreparedStatement對象this.pstmt=this.conn.prepareStatement(sql);this.pstmt.setString(1, gpslog.getLicenseplateno());this.pstmt.setDate(2, new java.sql.Date(gpslog.getIn_date().getTime()));this.pstmt.setDate(3, new java.sql.Date(gpslog.getGps_time().getTime()));this.pstmt.setString(4, gpslog.getLongitude());this.pstmt.setString(5, gpslog.getLatitude());this.pstmt.setString(6, gpslog.getHeight());this.pstmt.setString(7, gpslog.getSpeed());this.pstmt.setString(8, gpslog.getDirection());this.pstmt.setString(9, gpslog.getEff());this.pstmt.setString(10,gpslog.getCar_stat1() );this.pstmt.setString(11, gpslog.getCar_stat2());System.out.println("GpsLogDAOImpl.doCreate()=="+sql);if(this.pstmt.executeUpdate()>0){flag=true;}this.pstmt.close();//關閉PreparedStatement對象 return flag;}@Overridepublic void createTab() throws Exception {// TODO Auto-generated method stubSystem.out.println("GpsLogDAOImpl.createTab()");String sql="create table GPS_LOG_cxc"+ "( licenseplateno VARCHAR2(20) not null, "+ " in_date DATE default SYSDATE,"+ " gps_time DATE not null,"+ " longitude CHAR(10),"+ " latitude CHAR(9),"+ " height CHAR(9),"+ " speed CHAR(3),"+ " direction CHAR(3),"+ " eff CHAR(1),"+ " car_stat1 CHAR(1),"+ " car_stat2 CHAR(1)"+ ")";this.pstmt=this.conn.prepareStatement(sql);this.pstmt.execute();this.pstmt.close();}}
代理主題實現類代碼如下：

package com.test.dao;import java.sql.Connection;import com.test.dao.IGpsDao; import com.test.jdbc.IDBConnection; import com.test.jdbc.DBConnectionFactory; import com.test.vo.GPSLOG;public class GpsDaoProxy implements IGpsDao {//數據庫連接private IDBConnection dbc=null;//DAO對象private IGpsDao dao=null;public GpsDaoProxy(){System.out.println("GpsDaoProxy.GpsDaoProxy()");this.dbc =DBConnectionFactory.getDBConnection();//連接數據庫//實例化真實主題類--多態：接口對象指向實現此接口類的實例this.dao=new GpsLogDAOImpl(this.dbc.getConnection() );System.out.println("GpsDaoProxy.GpsDaoProxy()---2");}@Overridepublic boolean insertLog(GPSLOG gpslog) throws Exception {// TODO Auto-generated method stubSystem.out.println("GpsDaoProxy.doCreate()");boolean flag=false;try {flag=this.dao.insertLog(gpslog);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{this.dbc.close();}return flag;}@Overridepublic void createTab() throws Exception {// TODO Auto-generated method stubSystem.out.println("GpsDaoProxy.createTab()");try {this.dao.createTab();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{this.dbc.close();}}}
可以發現，在代理類的構造方法中實實例化了數據庫連接類的對象以及真實主題實現類，而在代理中的各個方法也只是調用了真實主題實現類中的相應方法。

3》DAO的真實實現類和代理實現類編寫完成后就需要編寫工廠類，以降低代碼間的耦合度。

package com.test.dao;import com.test.dao.IGpsDao;public class DAOFactory {public static IGpsDao getIGpsDaoInstance(){System.out.println("DAOFactory.getIGpsDaoInstance()");return new GpsDaoProxy();}} 至此DAO模式已經書寫完成。

其工程目錄結構如下圖所示：

（4）測試DAO插入功能 。

package com.test.main; import java.util.Date;import com.test.dao.DAOFactory; import com.test.vo.GPSLOG;public class Test { public static void main(String[] args) throws Exception { // TODO Auto-generated method stub GPSLOG gpslog=new GPSLOG();gpslog.setLicenseplateno("粵AW1V75");gpslog.setIn_date(new Date());gpslog.setGps_time(new Date());gpslog.setLongitude("+113.37310");gpslog.setLatitude("+23.13655");gpslog.setHeight("000");gpslog.setEff("0");gpslog.setSpeed("1");gpslog.setCar_stat1("2");gpslog.setCar_stat2("1");gpslog.setDirection("111");//測試增加數據庫操作DAOFactory .getIGpsDaoInstance().insertLog(gpslog);} }

結束。。。

完整代碼：點擊打開鏈接

總結

以上是生活随笔為你收集整理的DAO(Data Access Object ，数据访问对象)设计模式的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。