zoukankan      html  css  js  c++  java
  • jdbc之二:DAO模式 分类: B1_JAVA 2014-04-29 15:13 1536人阅读 评论(0) 收藏

    详细代码请参见 https://github.com/lujinhong/dao

    一、前期准备

    1、创建数据库

    create database filter_conf;

    2、创建表并插入数据

    create table T_CATEGORY(cid Int, title varchar(256), sequnce int, deleted int);

    insert into T_CATEGORY values(1,lujinhong,1,1);

    3、准备pom.xml

    我习惯使用maven作包管理,因此在pom.xml中加入以下内容:

    <dependency>

        <groupId>mysql</groupId>

        <artifactId>mysql-connector-java</artifactId>

        <version>5.1.36</version>

    </dependency>

    OK,开工写代码

    二、java创建 

    1、创建Dao接口。

    package com.ljh.jasonnews.server.dao;
    
    import java.sql.Connection;
    
    public interface Dao {
    	
    	public Connection getConnection() throws DaoException;
    
    }


    2、创建BaseDao类,实现Dao接口,主要完成数据库的打开与关闭

    package com.ljh.jasonnews.server.dao;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class DaoBase implements Dao {
    
    	@Override
    	public Connection getConnection() throws DaoException {
    	        try {
    	        	//注册JDBC驱动程序
    	        	Class.forName("com.mysql.jdbc.Driver");
    	        	
    				//打开一个数据库连接
    				String URL = "jdbc:mysql://1.2.3.4:3306/filter_conf";
    				String USERNAME = "lujinhong";
    				String PASSWORD = "lujinhong";
    
    	        	Connection conn = DriverManager.getConnection(URL,USERNAME,PASSWORD);
    				return conn;
    
    	        	
    	           //return dataSource.getConnection();
    	        } catch (Exception e) {
    	            e.printStackTrace();
    	            throw new DaoException();
    	        }
    	}
    	
    	protected void closeDbObject(ResultSet rs, Statement stmt, Connection conn){
    		if(rs != null){
    			try {
    				rs.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    		
    		if(stmt != null){
    			try {
    				stmt.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    		
    		if(conn != null){
    			try {
    				conn.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    	}
    


    3、创建DaoException。

     package com.ljh.jasonnews.server.dao;

    public class DaoException extends Exception{
    	private String message;
    	public DaoException(){}
    	public DaoException(String message){
    		this.message = message;
    	}
    	public String getMessage() {
    		return message;
    	}
    	public void setMessage(String message) {
    		this.message = message;
    	}
    	
    	public String toString(){
    		return message;
    	}
    
    }

    以上为jdbc DAO模式的基本步骤,主要用于获取连接及异常处理。

    以下步骤对于每个表均要进行新增类(***Dao,***DaoImpl,model.***)以及在类中新增方法(DaoFactory)。

    4、创建DaoFactory类,用于生产Dao对象。

    对于较少的连接,可以在factory中每次直接new 一个***DaoImpl对象,如本例。

    对于某些较多的连接,可能需要使用连接池等限制连接数量,说见本文最后面。

    package com.ljh.jasonnews.server.dao.factory;
    
    import com.ljh.jasonnews.server.dao.CategoryDao;
    import com.ljh.jasonnews.server.dao.impl.CategoryDaoImpl;
    
    public class DaoFactory {
    	
    	public static CategoryDao getCategoryDao() {
    		return new CategoryDaoImpl();
    	}
    }
    

    5、创建Model类。

    package com.ljh.jasonnews.server.model;
    
    
    public class Category {
    
    	public int getCid() {
    		return cid;
    	}
    	public void setCid(int cid) {
    		this.cid = cid;
    	}
    	public String getTitle() {
    		return title;
    	}
    	public void setTitle(String title) {
    		this.title = title;
    	}
    	public int getSequnce() {
    		return sequnce;
    	}
    	public void setSequnce(int sequnce) {
    		this.sequnce = sequnce;
    	}
    	public int getDeleted() {
    		return deleted;
    	}
    	public void setDeleted(int deleted) {
    		this.deleted = deleted;
    	}
    	private int cid;
    	private String title;
    	private int sequnce = 0;
    	private int deleted = 0;
    }


    6、创建***Dao接口,继承Dao接口。

    package com.ljh.jasonnews.server.dao;
    
    import java.util.List;
    
    import com.ljh.jasonnews.server.model.Category;
    
    public interface CategoryDao extends Dao{
    	
    	public List getCategoryList() throws DaoException;
    
    }


    7、创建***DaoImpl类,继承DaoBase类。

    package com.ljh.jasonnews.server.dao.impl;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.util.ArrayList;
    import java.util.List;
    
    import com.ljh.jasonnews.server.dao.CategoryDao;
    import com.ljh.jasonnews.server.dao.DaoBase;
    import com.ljh.jasonnews.server.dao.DaoException;
    import com.ljh.jasonnews.server.model.Category;
    
    public class CategoryDaoImpl extends DaoBase implements CategoryDao {
    
    	@Override
    	public List getCategoryList() throws DaoException{
    		
    		String GET_CATEGORY_SQL = "SELECT * FROM T_CATEGORY";
    
    		List categoryList = new ArrayList();
    		
    		Connection conn = null;
    		PreparedStatement pStatment =null;
    		ResultSet rs = null;
    		try{
    			conn = getConnection();
    			System.out.println("a");
    			pStatment = conn.prepareStatement(GET_CATEGORY_SQL);
    			System.out.println("b");
    			rs = pStatment.executeQuery();
    			System.out.println("c");
    			while(rs.next()){
    				Category category = new Category();
    				category.setCid(rs.getInt("cid"));
    				category.setTitle(rs.getString("title"));
    				category.setSequnce(rs.getInt("sequnce"));
    				category.setDeleted(rs.getInt("deleted"));
    				categoryList.add(category);
    			}
    		}catch(Exception e){
    			throw new DaoException("Erorr getting Categorys. " + e.getMessage());
    		}finally{
    			closeDbObject(rs, pStatment, conn);
    		}
    		
    		return categoryList;
    
    	}
     

     

    其它说明:

    1、创建TestCase,测试数据库连接。

    package com.ljh.jasonnews.server.dao.test;
    
    import java.util.Iterator;
    import java.util.List;
    
    import org.junit.Test;
    
    import com.ljh.jasonnews.server.dao.CategoryDao;
    import com.ljh.jasonnews.server.dao.impl.CategoryDaoImpl;
    import com.ljh.jasonnews.server.model.Category;
    
    public class CategoryDaoTest {
    
    	@Test
    	public void test() throws Exception{
    		CategoryDao categoryDao = DaoFactory.getCategoryDao();
    		List categoryList = categoryDao.getCategoryList();
    		Iterator iterator = categoryList.iterator();
    		while(iterator.hasNext()){
    			Category category = iterator.next();
    			System.out.println(category.getCid()+" "+ category.getTitle()+" "+category.getSequnce()+" "+ category.getDeleted()+"  ");
    		}
    		
    	}
    
    }
    

    2、在数据库中访问数据,最重要且最费时的操作经常是建立连接。按规则,设计良好的应用程序数据库连接应该始终是采用连接池的。

    一般而言,使用连接池有以下三种方法:

    l  Apache Commons DBCP

    l  C3p0

    l  Tomcat7中的Tomcat JDBCConnection Pool

        使用Tomcat的项目,建立直接使用TomcatJDBC Connection Pool。调用DataSource.getConnection()方法比较快,因为连接永远不会被关闭:关闭连接时,只要将连接返回池中即可。但是,JNDI查找比较慢,因此,被返回的DataSource经常会被缓存起来。

    注:

    (1)在调试中,未能使用连接池完成数据库连接,因此本示例中未使用连接池,关于连接池,可参考DataSourceCache.java,但关键是context.xml与web.xml中的配置。

    (2)在需要调用context相关的应用中,不能直接使用junit进行测试,而必须创建一个jsp或者servlet,否则,在以下代码中会报错:

     Context envContext = (Context)context.lookup("java:/comp/env");

    (3)作用连接池有JNDI及依赖注入2种方式,目前更推荐使用依赖注入。

    之后再补充关于连接池以及缓存相关的代码。

    版权声明:本文为博主原创文章,未经博主允许不得转载。

  • 相关阅读:
    关于最短路算法
    牛客网练习赛7-D-无向图(bfs,链式前向星)
    51nod蜥蜴与地下室(1498)(暴力搜索)
    poj1062昂贵的聘礼(枚举+最短路)
    训练题(代码未检验)(序列前k大和问题)
    两个序列求前k大和
    欧拉回路
    hdu 6063 RXD and math
    hdu 6066 RXD's date
    bzoj 4300 绝世好题
  • 原文地址:https://www.cnblogs.com/lujinhong2/p/4637345.html
Copyright © 2011-2022 走看看