java連線資料庫——純java封裝JDBC
阿新 • • 發佈:2018-12-09
第一步:
package com.qq.db; import java.sql.*; /* * 封裝一個數據庫的工具類 * 通用的獲取資料的方法 * 提高程式碼的高重用性 * */ public class DBunit { private static final String url = "jdbc:mysql://localhost:3306/qqdb"; private static final String user = "root"; private static final String password = "6612"; //封裝了一個公共的獲取資料庫的連線方法 public static Connection getConnection() { Connection conn = null; try { //1.載入驅動類 Class.forName("com.mysql.jdbc.Driver"); //2.建立資料庫的連線(提供url+使用者名稱+密碼),向java.sql.DriverManger請求並獲取Connection物件 conn = DriverManager.getConnection(url,user,password); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return conn; } //封裝一個查詢語句 public static ResultSet getQueryResult(String sql) { ResultSet rs = null; try { Connection conn = DBunit.getConnection(); Statement stat = conn.createStatement(); rs = stat.executeQuery(sql); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return rs; } }
第二步:測試
package com.qq; //封裝完之後用類名連線方式連線資料庫 import java.sql.*; import java.sql.DriverManager; import com.qq.db.DBunit;; public class TestDBC { public static void main(String[] args) { try { Connection conn = DBunit.getConnection(); String sql = "select * from t_user"; ResultSet rs = DBunit.getQueryResult(sql);//3.2相當於遊標 while(rs.next()) {//判斷是否有下一行 System.out.println(rs.getInt("id")+"\t"+rs.getString("name"));//輸出資料內容 } rs.close(); conn.close(); } catch (Exception e) { e.printStackTrace(); } } }