簡介

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;
  }

• 將查詢的結果集轉換為指定物件

  /**
   * <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();
        }
    }