DAO设计模式从开始到实现－详细到你不可思议

配置文件名为jdbc.properties

1. 创建dataSource和ThreadLock【】

   private static DataSource dataSource;
   private static final ThreadLocal ts = new ThreadLocal<>();
   

2. 读取配置文件【】

   InputStream is = JdbcUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");
   

3. 加载配置没见【】

   Properties ps = new Properties();
   ps.load(is);
   

4. 联接datasource【】

   dataSource = DruidDataSourceFactory.createDataSource(ps);
   

interface jdbcutil{

    public static Connection getConnection();//获取数据库连接

    public static PreparedStatement createPreparedStatement(String sql, Object... params) ;//由于PreparedStatement 既有预加载的性能可以提高速度，但是由于加载sql语句是insertinto tb_user values(?,?,?,...);的形式，故需要将params里面的值一一赋值；

    public static ResultSet executeQuery(String sql, Object... params);//获取数据库数据的方法，返回结果集 (ResultSet)；

    public static int executeUpdate(String sql, Object... params);//数据库增删改的操作，返回值是一个影响数据库行数的值；

    public static void releaseConnection();//关闭连接，实际是将数据库连接归还数据池

}

实体类

public class JdbcUtil implement jdbcutil{
	private JdbcUtil() {
	}

	private static DataSource dataSource;
	private static final ThreadLocal ts = new ThreadLocal<>();
	static {
		try {
			InputStream is = JdbcUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");
			Properties ps = new Properties();
			ps.load(is);
			dataSource = DruidDataSourceFactory.createDataSource(ps);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
//数据库增删改的操作，返回值是一个影响数据库行数的值；
	public static int executeUpdate(String sql, Object... params) {
		try {
			return createPreparedStatement(sql, params).executeUpdate();
		} catch (

		Exception e) {
			throw new RuntimeException(e.getMessage());
		}
	}
    //获取数据库数据的方法，返回结果集 
	public static ResultSet executeQuery(String sql, Object... params) {

		try {

			return createPreparedStatement(sql, params).executeQuery();
		} catch (Exception e) {
			throw new RuntimeException(e.getMessage());
		}
	}
//由于PreparedStatement 既有预加载的性能可以提高速度，但是由于加载sql语句是insertinto tb_user values(?,?,?,...);的形式，故需要将params里面的值一一赋值；
	public static PreparedStatement createPreparedStatement(String sql, Object... params) {
		try {
			Connection conn = getConnection();
			PreparedStatement ps = conn.prepareStatement(sql);
			if (params != null && params.length > 0)
				for (int i = 0; i < params.length; i++)
					ps.setObject(i + 1, params[i]);
			return ps;
		} catch (Exception e) {
			throw new RuntimeException(e.getMessage());
		}
	}

// 获取连接的方法
	public static Connection getConnection() {
		Connection res = ts.get(); 
		if (res == null) {
			try {
				res = dataSource.getConnection(); 
				ts.set(res); 
			} catch (Exception e) {
				throw new RuntimeException(e.getMessage());
			}
		}
		return res;
	}

// 释放连接的方法
	public static void releaseConnection() {
		Connection conn = ts.get(); 
		if (conn != null) {
			try {
				conn.close(); 
				ts.remove(); 
			} catch (Exception e) {
				throw new RuntimeException(e.getMessage());
			}
		}
	}
}

1. basedao接口dao类//定义数据库基本功能的接口【】

   public interface IBaseDao {
       public int save(T t);  
       public int delete(T t); 
       public int update(T t); 
       public List findByExample(T t);
   【
   //第一步获取调用new对象的Class反射类队形，以便于寻找数据库里面对应的表，进行数据操作
               private Class clazz;
               public BaseDaoImpl() {
                   Class clz = this.getClass();
                   Type type = clz.getGenericSuperclass();
                   // ParameterizedType参数化类型，即泛型
                   ParameterizedType p = (ParameterizedType) type;
                   // getActualTypeArguments获取参数化类型的数组，泛型可能有多个
                   clazz = (Class) p.getActualTypeArguments()[0];
                   System.out.println(clazz);
                }
   //第二步建立list集合来记录T类型里面的值，主要作用是为了给sql语句里面的参数（？）进行替换赋值
               List