碼上歡樂
相關內容    簡體    繁體

jdbc操作mysql

本文轉載自   查看原文   2016-05-16 09:51   16321    mysql/ java 開發

本文講述2點：

一. jdbc 操作 MySQL 。(封裝一個JdbcUtils.java類，實現數據庫表的增刪改查)

    1. 建立數據庫連接

       Class.forName(DRIVER);

       connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);

    2.用PrepareStatement執行sql語句

        pstmt = connection.prepareStatement(sql);

    3. 獲得執行Sql結果(int result)或結果集合（ResultSet）

        int result = pstmt.executeUpdate();  (增，刪，改)        

        ResultSet resultSet = pstmt.executeQuery(); (查詢)       

         // 獲取所有列的信息

        ResultSetMetaData metaData = resultSet.getMetaData(); 

 

二. 用Java反射機制返回JavaBean,List<JavaBean>

       看JdbcUtils.java 中具體代碼。

------------------------------------------------------------------------------------------------------------

程序思路：

用eclipse建立一個java 工程，訪問mysql數據庫。數據庫名稱：mydb,表格名稱：userinfo. user表格有三個屬性(id , username , pswd)

 

工程目錄：

 

1 JdbcUtils.java --封裝數據庫操作的類

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.dbutils;  
  2.   
  3. import java.lang.reflect.Field;  
  4. import java.sql.Connection;  
  5. import java.sql.DriverManager;  
  6. import java.sql.PreparedStatement;  
  7. import java.sql.ResultSet;  
  8. import java.sql.ResultSetMetaData;  
  9. import java.sql.SQLException;  
  10. import java.util.ArrayList;  
  11. import java.util.HashMap;  
  12. import java.util.List;  
  13. import java.util.Map;  
  14.   
  15. import com.jdbc.data.UserInfo;  
  16. import com.mysql.jdbc.Driver;  
  17.   
  18. public class JdbcUtils {  
  19.   
  20.     // 定義數據庫的用戶名  
  21.     private final String USERNAME = "root";  
  22.     // 定義數據庫的密碼  
  23.     private final String PASSWORD = "123456";  
  24.     // 定義數據庫的驅動信息  
  25.     private final String DRIVER = "com.mysql.jdbc.Driver";  
  26.     // 定義訪問數據庫的地址  
  27.     private final String URL = "jdbc:mysql://localhost:3306/mydb";  
  28.   
  29.     // 定義訪問數據庫的連接  
  30.     private Connection connection;  
  31.     // 定義sql語句的執行對象  
  32.     private PreparedStatement pstmt;  
  33.     // 定義查詢返回的結果集合  
  34.     private ResultSet resultSet;  
  35.   
  36.     public JdbcUtils() {  
  37.         // TODO Auto-generated constructor stub  
  38.         try {  
  39.             Class.forName(DRIVER);  
  40.             System.out.println("注冊驅動成功！！");  
  41.         } catch (ClassNotFoundException e) {  
  42.             // TODO Auto-generated catch block  
  43.             System.out.println("注冊驅動失敗！！");  
  44.         }  
  45.   
  46.     }  
  47.   
  48.     // 定義獲得數據庫的連接  
  49.     public Connection getConnection() {  
  50.   
  51.         try {  
  52.             connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);  
  53.   
  54.         } catch (Exception e) {  
  55.             // TODO: handle exception  
  56.             System.out.println("Connection exception !");  
  57.         }  
  58.   
  59.         return connection;  
  60.   
  61.     }  
  62.   
  63.     /** 
  64.      * 完成對數據庫標的增加刪除和修改的操作 
  65.      *  
  66.      * @param sql 
  67.      * @param params 
  68.      * @return 
  69.      * @throws SQLException 
  70.      */  
  71.     public boolean updateByPreparedStatement(String sql, List<Object> params)  
  72.             throws SQLException {  
  73.         boolean flag = false;  
  74.         int result = -1;// 表示當用戶執行增加刪除和修改的操作影響的行數  
  75.         int index = 1; // 表示 占位符 ，從1開始  
  76.         pstmt = connection.prepareStatement(sql);  
  77.         if (params != null && !params.isEmpty()) {  
  78.             for (int i = 0; i < params.size(); i++) {  
  79.                 pstmt.setObject(index++, params.get(i)); // 填充占位符  
  80.             }  
  81.         }  
  82.   
  83.         result = pstmt.executeUpdate();  
  84.         flag = result > 0 ? true : false;  
  85.         return flag;  
  86.   
  87.     }  
  88.   
  89.     /** 
  90.      * 查詢返回單條記錄 
  91.      *  
  92.      * @param sql 
  93.      * @param params 
  94.      * @return 
  95.      * @throws SQLException 
  96.      */  
  97.     public  Map<String, Object> findSimpleResult(String sql, List<Object> params)  
  98.             throws SQLException {  
  99.         Map<String, Object> map = new HashMap<String, Object>();  
  100.         pstmt = connection.prepareStatement(sql);  
  101.         int index = 1;  
  102.         if (params != null && !params.isEmpty()) {  
  103.             for (int i = 0; i < params.size(); i++) {  
  104.                 pstmt.setObject(index++, params.get(i));  
  105.             }  
  106.         }  
  107.         resultSet = pstmt.executeQuery(); // 返回查詢結果  
  108.   
  109.         ResultSetMetaData metaData = pstmt.getMetaData(); // 獲取 結果中，一行所有列的結果  
  110.         int cols_len = metaData.getColumnCount(); // 獲得列的總數  
  111.   
  112.         while (resultSet.next()) {  
  113.             for (int i = 0; i < cols_len; i++) {  
  114.                 String col_name = metaData.getColumnName(i + 1); // 獲得第i列的字段名稱  
  115.                 Object col_value = resultSet.getObject(col_name);// 返回 第i列的內容值  
  116.                 if (col_value == null) {  
  117.                     col_value = "";  
  118.                 }  
  119.                 map.put(col_name, col_value);  
  120.             }  
  121.   
  122.         }  
  123.   
  124.         return map;  
  125.     }  
  126.   
  127.     /** 
  128.      * 查詢返回多條記錄 
  129.      *  
  130.      * @param sql 
  131.      * @param params 
  132.      * @return 
  133.      * @throws SQLException 
  134.      */  
  135.     public List<Map<String, Object>> findMoreResult(String sql,  
  136.             List<Object> params) throws SQLException {  
  137.         List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();  
  138.         pstmt = connection.prepareStatement(sql);  
  139.         int index = 1; // 表示占位符  
  140.         if (params != null && !params.isEmpty()) {  
  141.             for (int i = 0; i < params.size(); i++) {  
  142.                 pstmt.setObject(index++, params.get(i));  
  143.             }  
  144.         }  
  145.         resultSet = pstmt.executeQuery(); // 返回查詢結果集合  
  146.         ResultSetMetaData metaData = resultSet.getMetaData(); // 獲得列的結果  
  147.   
  148.         while (resultSet.next()) {  
  149.             Map<String, Object> map = new HashMap<String, Object>();  
  150.             int cols_len = metaData.getColumnCount(); // 獲取總的列數  
  151.             for (int i = 0; i < cols_len; i++) {  
  152.                 String col_name = metaData.getColumnName(i + 1); // 獲取第 i列的字段名稱  
  153.                                                                     // ,列計算從1開始  
  154.                 Object col_value = resultSet.getObject(col_name); // 獲取第i列的內容值  
  155.                 if (col_value == null) {  
  156.                     col_value = "";  
  157.                 }  
  158.   
  159.                 map.put(col_name, col_value);  
  160.             }  
  161.             list.add(map);  
  162.         }  
  163.   
  164.         return list;  
  165.   
  166.     }  
  167.   
  168.     /** 
  169.      * 查詢返回單個JavaBean(使用java反射機制) 
  170.      *  
  171.      * @param sql 
  172.      * @param params 
  173.      * @param cls 
  174.      * @return 
  175.      * @throws Exception 
  176.      */  
  177.     public <T> T findSimpleRefResult(String sql, List<Object> params,  
  178.             Class<T> cls) throws Exception {  
  179.         T resultObject = null;  
  180.         int index = 1; // 占位符  
  181.         pstmt = connection.prepareStatement(sql);  
  182.         if (params != null && !params.isEmpty()) {  
  183.             for (int i = 0; i < params.size(); i++) {  
  184.                 pstmt.setObject(index++, params.get(i)); // 填充占位符  
  185.             }  
  186.         }  
  187.         resultSet = pstmt.executeQuery(); // 獲取查詢結果  
  188.   
  189.         ResultSetMetaData metaData = resultSet.getMetaData(); // 獲取列的信息  
  190.         int cols_len = metaData.getColumnCount(); // 獲取總的列數  
  191.         while (resultSet.next()) {  
  192.             // 通過反射機制創建實例  
  193.             resultObject = cls.newInstance(); // java反射機制  
  194.             for (int i = 0; i < cols_len; i++) {  
  195.                 String col_name = metaData.getColumnName(i + 1); // 獲取第i列的名稱  
  196.                 Object col_value = resultSet.getObject(col_name); // 獲取第i列的值  
  197.                 if (col_value == null) {  
  198.                     col_value = "";  
  199.                 }  
  200.                 Field field = cls.getDeclaredField(col_name);  
  201.                 field.setAccessible(true);// 打開 JavaBean的訪問 private權限  
  202.                 field.set(resultObject, col_value);  
  203.             }  
  204.   
  205.         }  
  206.   
  207.         return resultObject;  
  208.     }  
  209.   
  210.     /** 查詢返回多個JavaBean(通過java反射機制) 
  211.      * @param sql 
  212.      * @param params 
  213.      * @param cls 
  214.      * @return 
  215.      * @throws Exception 
  216.      */  
  217.     public <T> List<T> findMoreRefResult(String sql, List<Object> params,  
  218.             Class<T> cls) throws Exception {  
  219.         List<T> list = new ArrayList<T>();  
  220.         int index = 1; //占位符  
  221.         pstmt = connection.prepareStatement(sql);  
  222.         if (params != null && !params.isEmpty()) {  
  223.             for (int i = 0; i < params.size(); i++) {  
  224.                 pstmt.setObject(index++, params.get(i));  
  225.             }  
  226.         }  
  227.         resultSet = pstmt.executeQuery(); // 返回查詢結果集合  
  228.   
  229.         ResultSetMetaData metaData = resultSet.getMetaData(); // 返回列的信息  
  230.         int cols_len = metaData.getColumnCount(); // 結果集中總的列數  
  231.         while (resultSet.next()) {  
  232.             // 通過反射機制創建一個java實例  
  233.             T resultObject = cls.newInstance();  
  234.             for (int i = 0; i < cols_len; i++) {  
  235.                 String col_name = metaData.getColumnName(i + 1); // 獲得第i列的名稱  
  236.                 Object col_value = resultSet.getObject(col_name); // 獲得第i列的內容  
  237.                 if (col_value == null) {  
  238.                     col_value = "";  
  239.                 }  
  240.                 Field field = cls.getDeclaredField(col_name);  
  241.                 field.setAccessible(true); // 打開JavaBean的訪問private權限  
  242.                 field.set(resultObject, col_value);  
  243.             }  
  244.             list.add(resultObject);  
  245.   
  246.         }  
  247.   
  248.         return list;  
  249.     }  
  250.       
  251.     /**關閉數據庫訪問 
  252.      * @throws SQLException 
  253.      */  
  254.     public void releaseConn() throws SQLException{  
  255.         if (resultSet!=null) {  
  256.             resultSet.close();  
  257.         }  
  258.         if (pstmt!=null) {  
  259.             pstmt.close();  
  260.         }  
  261.         if (connection!=null) {  
  262.             connection.close();  
  263.         }  
  264.     }  
  265.   
  266.       
  267. }  

2. UserInfo.java (用來驗證java反射機制的JavaBean , 屬性名稱和數據表userinfo的字段完全一致)

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.data;  
  2.   
  3. import java.io.Serializable;  
  4.   
  5. public class UserInfo implements Serializable {  
  6.   
  7.     /** 
  8.      *  
  9.      */  
  10.     private static final long serialVersionUID = 1L;  
  11.     private int id;  
  12.     private String username;  
  13.     private String pswd;  
  14.   
  15.     public UserInfo() {  
  16.         // TODO Auto-generated constructor stub  
  17.     }  
  18.   
  19.     public int getId() {  
  20.         return id;  
  21.     }  
  22.   
  23.     public void setId(int id) {  
  24.         this.id = id;  
  25.     }  
  26.   
  27.     public String getUsername() {  
  28.         return username;  
  29.     }  
  30.   
  31.     public void setUsername(String username) {  
  32.         this.username = username;  
  33.     }  
  34.   
  35.     public String getPswd() {  
  36.         return pswd;  
  37.     }  
  38.   
  39.     public void setPswd(String pswd) {  
  40.         this.pswd = pswd;  
  41.     }  
  42.   
  43.     public static long getSerialversionuid() {  
  44.         return serialVersionUID;  
  45.     }  
  46.   
  47.     @Override  
  48.     public String toString() {  
  49.         return "UserInfo [id=" + id + ", username=" + username + ", pswd="  
  50.                 + pswd + "]";  
  51.     }  
  52.       
  53. }  

3. Test_insert.java  測試添加 

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.test;  
  2.   
  3. import java.sql.SQLException;  
  4. import java.util.ArrayList;  
  5. import java.util.List;  
  6.   
  7. import com.jdbc.dbutils.JdbcUtils;  
  8.   
  9. public class Test_Insert {  
  10.   
  11.     /** 
  12.      * @param args 
  13.      * @throws SQLException  
  14.      */  
  15.     public static void main(String[] args) throws SQLException {  
  16.       
  17.             JdbcUtils jdbcUtils = new JdbcUtils();  
  18.             jdbcUtils.getConnection();  
  19.               
  20.             //增加一條記錄。新增一個用戶信息 uername = "jack" , password = "admin"   
  21.             String sql = "insert into userinfo(username,pswd) values(?,?)";  
  22.             List<Object> params = new ArrayList<Object>();  
  23.             params.add("jack");  
  24.             params.add("admin");  
  25.               
  26.           
  27.             try {  
  28.                 boolean flag = jdbcUtils.updateByPreparedStatement(sql, params);      
  29.                 System.out.println("添加一條記錄： "+flag);  
  30.             } catch (Exception e) {  
  31.                 // TODO: handle exception  
  32.                 e.printStackTrace();  
  33.             }finally{  
  34.                 jdbcUtils.releaseConn();  
  35.             }  
  36.   
  37.   
  38.     }  
  39.   
  40. }  

運行結果：

（用同樣的方法，再增加一條記錄username="rose",pswd="123"）,此時數據庫共2條記錄。如下圖：

 

 

4. Test_FindMore.java (查詢多條記錄) 

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.test;  
  2.   
  3. import java.sql.SQLException;  
  4. import java.util.ArrayList;  
  5. import java.util.List;  
  6. import java.util.Map;  
  7.   
  8. import com.jdbc.dbutils.JdbcUtils;  
  9.   
  10. public class Test_FindMore {  
  11.   
  12.     /** 返回多條記錄 
  13.      * @param args 
  14.      * @throws Exception  
  15.      */  
  16.     public static void main(String[] args) throws Exception {  
  17.         // TODO Auto-generated method stub  
  18.         JdbcUtils jdbcUtils = new JdbcUtils();  
  19.         jdbcUtils.getConnection();    
  20.         String sql = "select * from userinfo";    
  21.           
  22.         try {  
  23.             List<Map<String, Object>> list = jdbcUtils.findMoreResult(sql, null);  
  24.             System.out.println(list);  
  25.         } catch (Exception e) {  
  26.             // TODO: handle exception  
  27.             e.printStackTrace();  
  28.         }finally{  
  29.             jdbcUtils.releaseConn();  
  30.         }  
  31.   
  32.     }  
  33.   
  34. }  

運行結果：

5. Test_FindSimple.java (查詢返回單條記錄)

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.test;  
  2.   
  3. import java.sql.SQLException;  
  4. import java.util.ArrayList;  
  5. import java.util.List;  
  6. import java.util.Map;  
  7.   
  8. import com.jdbc.dbutils.JdbcUtils;  
  9.   
  10. public class Test_FindSimple {  
  11.   
  12.     /**查詢返回一條記錄 
  13.      * @param args 
  14.      * @throws SQLException  
  15.      */  
  16.     public static void main(String[] args) throws SQLException {  
  17.         // TODO Auto-generated method stub  
  18.         JdbcUtils jdbcUtils = new JdbcUtils();  
  19.         jdbcUtils.getConnection();    
  20.         String sql = "select * from userinfo where username = ?";         
  21.         List<Object> params = new ArrayList<Object>();  
  22.         params.add("rose");  
  23.         try {  
  24.             Map<String, Object> map = jdbcUtils.findSimpleResult(sql, params);  
  25.             System.out.println(map);  
  26.         } catch (Exception e) {  
  27.             // TODO: handle exception  
  28.             e.printStackTrace();  
  29.         }finally{  
  30.             jdbcUtils.releaseConn();  
  31.         }  
  32.   
  33.     }  
  34.   
  35. }  

運行結果：

6.Test_RefMore.java 查詢返回List<JavaBean>(使用Java反射機制)

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.test;  
  2.   
  3. import java.sql.SQLException;  
  4. import java.util.List;  
  5. import java.util.Map;  
  6.   
  7. import com.jdbc.data.UserInfo;  
  8. import com.jdbc.dbutils.JdbcUtils;  
  9.   
  10. public class Test_RefMore {  
  11.   
  12.     /**返回List<JavaBean> (用Java反射機制) 
  13.      * @param args 
  14.      * @throws SQLException  
  15.      */  
  16.     public static void main(String[] args) throws SQLException {  
  17.         // TODO Auto-generated method stub  
  18.         JdbcUtils jdbcUtils = new JdbcUtils();  
  19.         jdbcUtils.getConnection();    
  20.         String sql = "select * from userinfo";    
  21.           
  22.         try {  
  23.             List<UserInfo> list = jdbcUtils.findMoreRefResult(sql, null , UserInfo.class);  
  24.             System.out.println(list);  
  25.         } catch (Exception e) {  
  26.             // TODO: handle exception  
  27.             e.printStackTrace();  
  28.         }finally{  
  29.             jdbcUtils.releaseConn();  
  30.         }  
  31.   
  32.     }  
  33.   
  34. }  

7. Test_RefSimple.java 查詢返回單個JavaBean (使用Java反射機制)

[java]  view plain  copy
 在CODE上查看代碼片派生到我的代碼片
  1. package com.jdbc.test;  
  2.   
  3. import java.sql.SQLException;  
  4. import java.util.ArrayList;  
  5. import java.util.List;  
  6. import java.util.Map;  
  7.   
  8. import com.jdbc.data.UserInfo;  
  9. import com.jdbc.dbutils.JdbcUtils;  
  10.   
  11. public class Test_RefSimple {  
  12.   
  13.     /**返回一個JavaBean (用Java反射機制) 
  14.      * @param args 
  15.      * @throws SQLException  
  16.      */  
  17.     public static void main(String[] args) throws SQLException {  
  18.         // TODO Auto-generated method stub  
  19.         JdbcUtils jdbcUtils = new JdbcUtils();  
  20.         jdbcUtils.getConnection();    
  21.         String sql = "select * from userinfo where username = ?";         
  22.         List<Object> params = new ArrayList<Object>();  
  23.         params.add("rose");  
  24.           
  25.         try {  
  26.             UserInfo userInfo = jdbcUtils.findSimpleRefResult(sql, params, UserInfo.class);  
  27.             System.out.println(userInfo);  
  28.         } catch (Exception e) {  
  29.             // TODO: handle exception  
  30.             e.printStackTrace();  
  31.         }finally{  
  32.             jdbcUtils.releaseConn();  
  33.         }  
  34.   
  35.     }  
  36.   
  37. }  

運行結果：

 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 JDBC操作MySQL 使用JDBC操作MySQL數據庫 為什么使用JDBC操作MySQL需要添加Class.forName("com.mysql.jdbc.Driver") JavaEE系列之（三）JDBC操作MySQL數據庫 JDBC操作mysql數據庫(SqlHelper類封裝) springboot之整合基本的jdbc並操作Mysql數據庫 mysql數據庫__Jdbc直接操作__PreparedStatement__insert MySQL JDBC 連接數據庫基本操作 Spring JDBC框架操作mysql數據庫 JDBC連接mysql數據庫並進行簡單操作
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM