java的分层开发

既然是分层开发,首先我们需要知道的是分为那几个层,并且是干什么的?

1.实体层(entity) 对应数据库中的一张表,有了它可以降低耦合性,同时也是数据的载体.

2.数据访问对象(data access object)主要包含两个java源文件,一个是BaseBao,还有一个是所需要查询表的接口

package cn.news.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.junit.Test;

/**
 * 数据访问工具类
 * @version 1.1
 * @author happy
 *
 */
public class BaseDao {
   private static final String driver="com.microsoft.sqlserver.jdbc.SQLServerDriver";
   private static final String url="jdbc:sqlserver://localhost:1433;DataBaseName=s2223";
   private static final String username="sa";
   private static final String pwd="6375196";
   
   Connection con=null;
   PreparedStatement ps=null;
   ResultSet rs=null;
   //01.写一个用户获取到一个连接对象的方法，方法的返回值是Connection类型
   /**
    * 01.写一个用户获取到一个连接对象的方法，方法的返回值是Connection类型
    * @return   连接对象
    * @throws Exception
    */
   public Connection getConnection() throws Exception{
       Class.forName(driver);
       //什么条件下，构建connection对象
       if (con==null||con.isClosed()) {
           con=DriverManager.getConnection(url, username, pwd);
        }
       //同志们碰到一个
       return con;
   }
   
   
   //单元测试
   //java junit
   @Test
   public void testQuery() throws Exception{
       ResultSet rs = executeQuery("select * from student");
       if(rs!=null){
           while (rs.next()) {
            String name = rs.getString("sname");
            System.out.println(name);
        }
       }
   }
   //测试添加
   @Test
   public void testUpdate() throws Exception{
     int count=  executeUpdate("update student set sname='大强' where sname='黄强'");
     System.out.println(count);
   }
   
   
   
   //执行查询操作  目的：返回一个读取器
   /**
    * 执行查询操作  目的：返回一个读取器
    * @param sql  sql语句
    * @param objs  参数列表
    * @return     读取器对象
    * @throws Exception
    */
   public ResultSet  executeQuery(String sql,Object... objs) throws Exception{
       con=getConnection();
       ps = con.prepareStatement(sql);
       for (int i = 0; i < objs.length; i++) {
           ps.setObject(i+1, objs[i]);
       }
       rs= ps.executeQuery();
       return rs;
   }
   
   
   //执行增删该操作
   /**
    * 执行增删该操作
    * @param sql  sql语句
    * @param objs  参数列表
    * @return     受影响行数
    * @throws Exception
    */
   public int executeUpdate(String sql,Object... objs) throws Exception{
        con=getConnection();
        ps = con.prepareStatement(sql);
        for (int i = 0; i < objs.length; i++) {
               ps.setObject(i+1, objs[i]);
        }
        int count = ps.executeUpdate(); 
        return count;
   }
   
   
   
   //2.回收连接资源
  /**
   * 回收连接资源
   * @throws Exception
   */
   public void closeAll() throws Exception{
       if(rs!=null){
           rs.close();
       }
       if (ps!=null) {
        ps.close();
       }
       if(con!=null){
           con.close();
       }
       
   }
   
}