Java JDBC简单入门之枚举（Enum）、泛型、反射、JDBC整合

• • 简介
  • 环境准备
  • 项目目录
    • 所用jar包
    • 数据库连接配置
    • JDBC配置文件
    • 运行测试

---

简介

JDBC（Java DataBase Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序
标注：以上引用自百度百科JDBC

环境准备

Eclipse+JDK8+Mysql

项目目录

本文笔者采用java 应用程序的方式搭建简单的jdbc项目

所用jar包

数据库连接配置

• 加载JDBC配置文件（jdbc.properties）

/** * 实例化Properties */
    private static Properties properties = new Properties();
    static {
        /** * 加载配置文件 (1)类的绝对路径：Class.class.getClass().getResource("/").getPath() */
        try {
            properties.load(JDBCTemplate.class.getResourceAsStream("jdbc.properties"));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

• 设置链接配置

  private static Connection connection = null;
  private static PreparedStatement preparedstatement = null;
  private static ResultSet resultSet = null;
  /** * <p> * Title: precompile * </p> * <p> * Description: * </p> * * @param sql * @throws ClassNotFoundException * @throws SQLException */
  private static void precompile(String sql) throws Exception {
      /** * 指定连接 driver */
      Class.forName(properties.getProperty("jdbc.driver"));
      /** * 获取数据库连接 */
      connection = DriverManager.getConnection(properties.getProperty("jdbc.url"),
              properties.getProperty("jdbc.user"), properties.getProperty("jdbc.password"));
      /** * 预编译sql */
      preparedstatement = connection.prepareStatement(sql);
  
  }
  /** * <p> * Title: close * </p> * <p> * Description: 关闭连接 * </p> */
  private static void close() {
      try {
          connection.close();
          preparedstatement.close();
      } catch (SQLException e) {
          e.printStackTrace();
      }
  }

• 执行SQL操作（本文笔者增删改查混合封装，建议笔者查单独封装）

  /** * 执行sql * <p> * Title: executeQuery * </p> * <p> * Description: operation：操作 ①：JdbcMode.QUERY.operation() 查询 * ②：JdbcMode.INSERT.operation()插入 ③：JdbcMode.UPDATE.operation()更新 * ④：JdbcMode.DELETE.operation()删除 claszz： 指定返回值类型(增删改可传null),查询操作返回List<T>。 * </p> * * @param sql * 执行sql * @param operation * 操作 * @param claszz * 返回值类型 * @param params * 设置占位符?的值(注意参数顺序)(无占位符可为null) * @return Object * @throws Exception */
  public static <T> Object execute(String sql, List<Object> params, String operation, Class<T> claszz)
          throws Exception {
      /** * 预编译sql */
      precompile(sql);
      /** * 设置占位符?的值(注意参数顺序) */
      if (params != null && params.size() > 0) {
          for (int i = 0; i < params.size(); i++) {
              preparedstatement.setObject(i + 1, params.get(i));
          }
      }
      switch (JdbcMode.getByValue(operation)) {
      case UPDATE:
          /** * 执行修改操作 */
          int countu = preparedstatement.executeUpdate();
          close();
          return countu;
      case INSERT:
          /** * 执行插入操作 */
          int counti = preparedstatement.executeUpdate();
          close();
          return counti;
      case DELETE:
          /** * 执行删除操作 */
          int countd = preparedstatement.executeUpdate();
          close();
          return countd;
      case QUERY:
          /** * 执行查询得到结果集 */
          resultSet = preparedstatement.executeQuery();
          List<T> listT = getModel(resultSet, claszz);
          close();
          return listT;
      default:
          break;
      }
      /** * 关闭连接 */
      close();
      return null;
  }

  PS:枚举常量使用请参阅笔者Java枚举（ENUM）用法之常量博文

• 将查询的结果集转换为指定对象

  /** * <p> * Title: getModel * </p> * <p> * Description: 将结果集中的数据装换为对象 * </p> * * @param resultSet * @param t * @return * @throws Exception */
  @SuppressWarnings("unchecked")
  private static <T> List<T> getModel(ResultSet resultSet, Class<T> claszz) throws Exception {
      ResultSetMetaData metadata = resultSet.getMetaData();
      List<T> listT = new ArrayList<>();
      while (resultSet.next()) {
          int columncount = metadata.getColumnCount();
          if (columncount == 1) {
              listT.add((T) resultSet.getObject(1));
          } else {
              Map<String, Object> mapdata = new HashMap<>();
              for (int i = 1; i <= columncount; i++) {
                  // 获得指定列的列名
                  String columnName = metadata.getColumnName(i);
                  // 获得指定列的列值
                  Object columnValue = resultSet.getObject(i);
                  mapdata.put(columnName, columnValue);
              }
              T obj = claszz.newInstance();
              BeanUtils.populate(obj, mapdata);
              listT.add(obj);
          }
      }
      return listT;
  }
  

JDBC配置文件

#数据库连接
jdbc.url=jdbc:mysql://...../databasename?useUnicode=true&characterEncoding=utf8
#数据库驱动
jdbc.driver=com.mysql.jdbc.Driver
#用户名
jdbc.user=user
#密码
jdbc.password=pwd

运行测试

    public static void main(String[] args) {
        String sql="select * from t_user_login";
        try {
            @SuppressWarnings("unchecked")
            List<User> users=(List<User>) JDBCTemplate.execute(sql, null, JdbcMode.QUERY.operation(), User.class);
            for (User user : users) {
                System.out.println(user.getLoginid()+"::::::::::"+user.getUsername());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

项目源码下载地址