一个简单的DAO例子

    第一次写博客,总感觉怪怪的,可能是我语文考试时作文老是写一半吧,所以,有点小紧张是在所难免的哈,当然,火眼金睛的各位可不要手下留情哦,欢迎纠正这篇菜鸟文章的错误~有你的支持,才是我们程序菜鸟员的动力!     

     此例子呢只是做一个简单的注册和查询，

 

开发工具: MyEclipse 8.6

数据库:MySQL

(例子尽在下载解压缩中…)

 

 

 

 

MySQL数据库设计

 

 

 

 

 

项目名MyDAO

 

类的命名:（小提示，包和类的命名需要规范哦）

dao接口类

factory工厂类

impl真实类

proxy代理类

数据库连接类

JUnit测试类

vo类: Myemp.java

引用的驱动: 数据库连接驱动包mysql-connector-java-5.1.18-bin.jar

 

 

 

 

接下来的会通过一个小故事将代码呈现：vo-原料  数据库-原料商 DAO接口-师傅 Impl-dao的徒弟 Proxy-小代理 JUnit-dao一族的死党 

 

 

一，创建VO类: 一大堆原料

 

package org.yzsoft.demo.vo;

 

public class Myemp {

    private int id;         //标识

    private String username;//用户名

    private String password;//密码

    /* 以下为Get Set访问 */

    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 String getPassword() {

       return password;

    }

    public void setPassword(String password) {

       this.password = password;

    }

}

 

 

二，

 

 

 

 

 

 

 

数据库连接类:这批货(原料)怎么推销出去呢? 货物积存了可不妙啊

 

package org.yzsoft.demo.util;

 

import java.sql.Connection;

import java.sql.DriverManager;

 

public class DatabaseConnection {

    private static final String DBDRIVER = "org.gjt.mm.mysql.Driver";

    private static final String DBURL = "jdbc:mysql://localhost:3306/hxl";// 数据库地址

    private static final String DBUSER = "root";

    private static final String DBPASSWORD = "admin";

    private Connection conn = null;

 

    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;

           }

       }

    }

}

 

 

三，DAO接口-师傅:技术我有,Impl这小子学不学得精,那就要看他的造化了…

 

package org.yzsoft.demo.dao;

 

 

import java.util.List;

import org.yzsoft.demo.vo.Myemp;

 

public interface IMyempDAO {

    /**

     * 数据的增加操作

     * @param emp 要增加的对象

     * @return 是否增加成功的标记

     * @throws Exception 异常交给被调用处处理

     */

    public boolean doCreate(Myemp emp) throws Exception ;

    /**

     * 根据关键字查询数据

     * @param  keyWord 查询条件

     * @return 查询到的数据集合

     * @throws Exception 异常交给被调用处处理

     */

    public List<Myemp> findAll(String keyWord) throws Exception ;

}

 

 

 

 

四，真实类-DAOImpl小子: 我要努力学习印刷术,不过我得采购些原料,去哪找呢?印刷不能停,可这样一来没时间去做其它事情了呀

 

 

 

 

 

package org.yzsoft.demo.impl;

 

import java.util.*;

 

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

 

import org.yzsoft.demo.dao.IMyempDAO;

import org.yzsoft.demo.vo.Myemp;

 

 

public class MyempDAOImpl implements IMyempDAO {

    private Connection conn = null;

    private PreparedStatement pstmt = null;

 

    public MyempDAOImpl(Connection conn) {//构造方法取得与数据库连接

       this.conn = conn;

    }

 

    public boolean doCreate(Myemp emp) throws Exception {

       boolean flag = false;

       String sql = "INSERT INTO myemp(username,password) VALUES (?,?)"; //SQL插入语句

       this.pstmt = this.conn.prepareStatement(sql);                     //预编译

       this.pstmt.setString(1, emp.getUsername());                       //设置用户名

       this.pstmt.setString(2, emp.getPassword());                       //设置密码

       if (this.pstmt.executeUpdate() > 0) { //如果有更新记录 标记为true

           flag = true;

       }

       this.pstmt.close();  //关闭打开的操作

       return flag;

    }

 

    public List<Myemp> findAll(String keyWord) throws Exception {

       List<Myemp> all = new ArrayList<Myemp>();     //定义集合接收数据

       String sql = "SELECT id,username,password FROM myemp WHERE username LIKE ? OR password LIKE ?"; //SQL查询语句

       this.pstmt = this.conn.prepareStatement(sql); //预编译

       this.pstmt.setString(1, "%" + keyWord + "%"); //设置用户名 模糊查询

       this.pstmt.setString(2, "%" + keyWord + "%"); //设置密码 模糊查询

       ResultSet rs = this.pstmt.executeQuery();     //接收数据

       Myemp emp = null;

       while (rs.next()) {  //依次将数据就存入VO,向集合增加

           emp = new Myemp();

           emp.setId(rs.getInt(1));

           emp.setUsername(rs.getString(2));

           emp.setPassword(rs.getString(3));

           all.add(emp);

       }

       this.pstmt.close();  //关闭打开的操作

       return all;          //返回结果

    }

}

 

 

 

五，代理类-小代理Proxy:Impl这家伙呆呆的,就知道钻研技术,生意上的事还是由我来帮他搞定吧!

 

package org.yzsoft.demo.proxy;

 

import java.util.*;

 

import org.yzsoft.demo.dao.IMyempDAO;

import org.yzsoft.demo.impl.MyempDAOImpl;

import org.yzsoft.demo.util.DatabaseConnection;

import org.yzsoft.demo.vo.Myemp;

 

public class MyempDAOProxy implements IMyempDAO {

    private DatabaseConnection dbc = null; //定义数据库连接类

    private IMyempDAO dao = null;          //声明DAO

 

    public MyempDAOProxy() throws Exception {//构造方法中实例化连接与实例化DAO对象

       this.dbc = new DatabaseConnection();  //连接数据库

       this.dao = new MyempDAOImpl(this.dbc.getConnection());//实例化真实类

    }

 

    public boolean doCreate(Myemp emp) throws Exception {

       boolean flag = false;

       try {

           flag = this.dao.doCreate(emp);   //调用真实类的doCreate方法

       } catch (Exception e) {

           throw e;

       } finally {

           this.dbc.close();                //关闭数据库连接

       }

       return flag;

    }

 

    public List<Myemp> findAll(String keyWord) throws Exception {

       List<Myemp> all = null;

       try {

           all = this.dao.findAll(keyWord); //调用真实类的findAll方法

       } catch (Exception e) {

           throw e;

       } finally {

           this.dbc.close();                //关闭数据库连接

       }

       return all;

    }

}

DAO代理类:不过,该怎么吸引更多的客户呢? 咦,打个广告怎样,这样,通过广告就可以吸引好多人

 

 

 

六，工厂类-广告! //

 

package org.yzsoft.demo.factory;

 

import org.yzsoft.demo.dao.IMyempDAO;

import org.yzsoft.demo.proxy.MyempDAOProxy;

 

public class DAOFactory {

    public static IMyempDAO getIEmpDAOInstance() throws Exception { //取得DAO接口实例

       return new MyempDAOProxy(); //取得代理类的实例

    }

}

 

 

 

客户上门咯（注册的JSP页面）

  

page contentType="text/html" pageEncoding="UTF-8"%>

<html>

<head><title>This is DAO demo</title></head>

<body>

<form action="insert_do.jsp" method="post">

    用户：<input type="text" name="username"><br>

    密码：<input type="text" name="password"><br>

    <input type="submit" value="注册">

    <input type="reset" value="重置">

</form>

</body>

</html>

 

 

 

恰谈中（注册检查的JSP页面）

 

 

 

 

 

<%@ page contentType="text/html" pageEncoding="UTF-8"%>

<%@ page import="java.text.*"%>

<%@page import="org.yzsoft.demo.vo.Myemp"%>

<%@page import="org.yzsoft.demo.factory.DAOFactory"%>

<html>

<head><title>This is DAO demo check</title></head>

<%  request.setCharacterEncoding("UTF-8"); %>

<body>

<%

    Myemp emp = new Myemp() ;

    emp.setUsername(request.getParameter("username")) ;

    emp.setPassword(request.getParameter("password")) ;

try{

    if(DAOFactory.getIEmpDAOInstance().doCreate(emp)){

%>

       <h3>注册成功！</h3>

<%

    } else {

%>

       <h3>注册失败！</h3>

<%

    }

%>

<%

}catch(Exception e){

    e.printStackTrace() ;

}

%>

</body>

</html>

 

 

 

 

合作愉快（查询的结果页）

 

<%@ page contentType="text/html" pageEncoding="UTF-8"%>

<%@ page import="java.util.*"%>

<%@page import="org.yzsoft.demo.vo.Myemp"%>

<%@page import="org.yzsoft.demo.factory.DAOFactory"%>

<html>

<head><title>This is DAO demo list</title></head>

<%  request.setCharacterEncoding("UTF-8") ;   %>

<body>

<%

    String keyWord = request.getParameter("keyword") ;

    if(keyWord == null){

       keyWord = "" ;    // 如果没有查询关键字，则查询全部

    }

    List<Myemp> all = DAOFactory.getIEmpDAOInstance().findAll(keyWord) ;

    Iterator<Myemp> iter = all.iterator() ;

%>

<center>

<form action="list.jsp" method="post">

    请输入查询关键字：<input type="text" name="keyword">

    <input type="submit" value="查询">

</form>

<table border="1" width="70%">

    <tr>

       <td>序号</td>

       <td>用户名</td>

       <td>密码</td>

    </tr>

<%

    while(iter.hasNext()){

       Myemp emp = iter.next() ;

%>

    <tr>

       <td><%=emp.getId()%></td>

       <td><%=emp.getUsername()%></td>

       <td><%=emp.getPassword()%></td>

    </tr>

<%

    }

%>

</table>

</center>

</body>

</html>

 

 

以上就是一个简单的dao小例子，