普通Dao操作通用步骤

1.写SQL语句

2.获取连接

3.创建PreparedStatement

4.执行sql语句

a)更新
b)查询

5.关闭/异常

BaseDao的实现

BaseDao是自己写的通用的dao父类，自己写的所有的dao都继承这个父类dao

通用方法

• 更新类别的:update , delete , insert

• 查询类别的

代码中用到元数据方法简书地址：数据库之元数据——DatabaseMetaData

package com.eu.dss.dao;

import com.eu.dss.util.ConnUtil;
import java.util.List;
import org.apache.commons.beanutils.BeanUtils;
import java.sql.*;
import java.util.ArrayList;

/**
 * Created by 马欢欢 on 2017/5/18.
 */
public class BaseDao {
    private Connection conn;
    private PreparedStatement pstmt;
    private ResultSet rs;

    /**
     * 更新的通用方法
     * 更新的sql语句（update/insert/delete）
     * paramsValue  sql语句中占位符对应的值（如果没有占位符，传入null）
     */
    public void update(String sql, Object[] paramsValue) {
        try {
            //获取连接
            conn = ConnUtil.getConnextion();
            //创建执行任务
            pstmt = conn.prepareStatement(sql);
            //参数元数据: 得到占位符参数的个数
            int count = pstmt.getParameterMetaData().getParameterCount();
            //判断是否有条件
            if (paramsValue != null && paramsValue.length > 0) {
                //循环给参数赋值
                for (int i = 0; i < count; i++) {
                    pstmt.setObject(i + 1, paramsValue[i]);
                }
            }
            pstmt.executeUpdate();
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            ConnUtil.close(null, pstmt, conn);

        }
    }

    /**
     * 查询通用方法
     */
    public <T> List<T> query (String sql, Object[] paramsValue , Class<T> tClass){
        List <T> list = new ArrayList<T>();
        //获取连接
        conn = ConnUtil.getConnextion();
        try {
            //创建对象
            pstmt = conn.prepareStatement(sql);
            int count = pstmt.getParameterMetaData().getParameterCount();
            if(paramsValue !=null && paramsValue.length> 0 ){
                for(int i=0;i<paramsValue.length;i++){
                    pstmt.setObject(i+1,paramsValue[i]);
                }
            }
            rs = pstmt.executeQuery();
            //拿到结果集元数据
            ResultSetMetaData rsmd = rs.getMetaData();
            //获取列的个数
            int culumnCount =rsmd.getColumnCount();
            T t;
            while(rs.next()){
                t = tClass.newInstance();
                for (int i = 0; i<culumnCount;i++){
                    String coulumnName =rsmd.getColumnName(i+1);
                    Object value = rs.getObject(coulumnName);
                    BeanUtils.copyProperty(t,coulumnName,value);
                }
                list.add(t);
            }
            return list;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

}

DAO层: 下来我们在写Dao层的代码时就特别简单

下面示例：

• 查询数据
• 查找数据按照id
• 插入数据
• 更新数据
• 删除数据

package com.eu.dss.dao.impl;

import com.eu.dss.dao.BaseDao;
import com.eu.dss.dao.ITronClassDao;
import com.eu.dss.entity.TronClasstype;
import net.sf.json.JSONArray;

import java.util.List;

/**
 * Created by 马欢欢 on 2017/5/23.
 */
public class TronClassDao extends BaseDao implements ITronClassDao  {

    public List<TronClasstype> TronClasstype() {
        String sql = " SELECT * FROM eu_tronclass ; ";
        List <TronClasstype> list = super.query(sql,null,TronClasstype.class);
        JSONArray jsonArray = JSONArray.fromObject(list);
        System.out.println("bbbb"+jsonArray);
        return list;
    }

    public TronClasstype findByid(int id) {
        String sql = " SELECT * FROM eu_tronclass where id=? ; ";
        List <TronClasstype> list = super.query(sql,new Object[id],TronClasstype.class);
        return (list!=null && list.size()>0) ? list.get(0) : null;
    }

    public void save(TronClasstype tronClassType) {
        String sql = " INSERT INTO eu_tronclass (year,tron_month,eu_rj,eu_xin,eu_rw,eu_ts,eu_xiu,eu_gz,eu_kuai,eu_ad,eu_wc,eu_wu,eu_jr) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?); ";
        Object[] paramsValue = {tronClassType.getYear(),tronClassType.getTron_month(),
                tronClassType.getEu_rj(),   tronClassType.getEu_xin(),
                tronClassType.getEu_rw(),   tronClassType.getEu_ts(),
                tronClassType.getEu_xiu(),  tronClassType.getEu_gz(),
                tronClassType.getEu_kuai(), tronClassType.getEu_ad(),
                tronClassType.getEu_wc(),   tronClassType.getEu_wu(),
                tronClassType.getEu_jr()};
        super.update(sql,paramsValue);
    }

    public void update(TronClasstype tronClassType ) {
        String sql = " UPDATE eu_tronclass SET year = ?,tron_month =?,eu_rj =?," +
                "eu_xin =?,eu_rw=?,eu_ts=?,eu_xiu=?,eu_gz=?,eu_kuai=?," +
                "eu_ad=?,eu_wc=?,eu_wu=?,eu_jr=? where id=?";
        Object[] paramsValue = {tronClassType.getYear(),tronClassType.getTron_month(),
                tronClassType.getEu_rj(),   tronClassType.getEu_xin(),
                tronClassType.getEu_rw(),   tronClassType.getEu_ts(),
                tronClassType.getEu_xiu(),  tronClassType.getEu_gz(),
                tronClassType.getEu_kuai(), tronClassType.getEu_ad(),
                tronClassType.getEu_wc(),   tronClassType.getEu_wu(),
                tronClassType.getEu_jr(),   tronClassType.getId()};
        super.update(sql,paramsValue);
    }
    public void delete(int id) {
        String sql = " delete from eu_tronclass where id =? ";
        Object[] paramsValue = {id};
        super.update(sql,paramsValue);
    }
}

文章文集：JavaEE–学习笔记