Java JDBC簡單入門之列舉(Enum)、泛型、反射、JDBC整合
阿新 • • 發佈:2019-02-19
簡介
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操作(本文筆者增刪改查混合封裝,建議筆者查單獨封裝)
/** * 執行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();
}
}