2. 程式人生 > >java（JDBC連線資料庫）[完整版封裝]

java（JDBC連線資料庫）[完整版封裝]

阿新 • • 發佈：2018-12-31
  1. import java.sql.CallableStatement;  
  2. import java.sql.Connection;  
  3. import java.sql.DriverManager;  
  4. import java.sql.PreparedStatement;  
  5. import java.sql.ResultSet;  
  6. import java.sql.ResultSetMetaData;  
  7. import java.sql.SQLException;  
  8. import java.util.ArrayList;  
  9. import java.util.HashMap;  
  10. import java.util.List;  
  11. import java.util.Map;  
  12. /** 
  13.  * 資料庫連線類 
  14.  * 說明:封裝了 無參，有參，儲存過程的呼叫 
  15.  * @author iflytek 
  16.  * 
  17.  */
  18. publicclass ConnectionDB {  
  19.     /** 
  20.      * 資料庫驅動類名稱 
  21.      */
  22.     privatestaticfinal String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";  
  23.     /** 
  24.      * 連線字串
     
  25.      */
  26.     privatestaticfinal String URLSTR = "jdbc:sqlserver://localhost:1433; databaseName=Northwind";  
  27.     /** 
  28.      * 使用者名稱 
  29.      */
  30.     privatestaticfinal String USERNAME = "sa";  
  31.     /** 
  32.      * 密碼 
  33.      */
  34.     privatestaticfinal String USERPASSWORD = "111111";  
  35.     /** 
  36.      * 建立資料庫連線物件
     
  37.      */
  38.     private Connection connnection = null;  
  39.     /** 
  40.      * 建立PreparedStatement物件 
  41.      */
  42.     private PreparedStatement preparedStatement = null;  
  43.     /** 
  44.      * 建立CallableStatement物件 
  45.      */
  46.     private CallableStatement callableStatement = null;  
  47.     /** 
  48.      * 建立結果集物件 
  49.      */
  50.     private ResultSet resultSet = null;  
  51.     static {  
  52.         try {  
  53.             // 載入資料庫驅動程式
  54.             Class.forName(DRIVER);  
  55.         } catch (ClassNotFoundException e) {  
  56.             System.out.println("載入驅動錯誤");  
  57.             System.out.println(e.getMessage());  
  58.         }  
  59.     }  
  60.     /** 
  61.      * 建立資料庫連線 
  62.      * @return 資料庫連線 
  63.      */
  64.     public Connection getConnection() {  
  65.         try {  
  66.             // 獲取連線
  67.             connnection = DriverManager.getConnection(URLSTR, USERNAME,  
  68.                     USERPASSWORD);  
  69.         } catch (SQLException e) {  
  70.             System.out.println(e.getMessage());  
  71.         }  
  72.         return connnection;  
  73.     }  
  74.     /** 
  75.      * insert update delete SQL語句的執行的統一方法 
  76.      * @param sql SQL語句 
  77.      * @param params 引數陣列，若沒有引數則為null 
  78.      * @return 受影響的行數 
  79.      */
  80.     publicint executeUpdate(String sql, Object[] params) {  
  81.         // 受影響的行數
  82.         int affectedLine = 0;  
  83.         try {  
  84.             // 獲得連線
  85.             connnection = this.getConnection();  
  86.             // 呼叫SQL 
  87.             preparedStatement = connnection.prepareStatement(sql);  
  88.             // 引數賦值
  89.             if (params != null) {  
  90.                 for (int i = 0; i < params.length; i++) {  
  91.                     preparedStatement.setObject(i + 1, params[i]);  
  92.                 }  
  93.             }  
  94.             // 執行
  95.             affectedLine = preparedStatement.executeUpdate();  
  96.         } catch (SQLException e) {  
  97.             System.out.println(e.getMessage());  
  98.         } finally {  
  99.             // 釋放資源
  100.             closeAll();  
  101.         }  
  102.         return affectedLine;  
  103.     }  
  104.     /** 
  105.      * SQL 查詢將查詢結果直接放入ResultSet中 
  106.      * @param sql SQL語句 
  107.      * @param params 引數陣列，若沒有引數則為null 
  108.      * @return 結果集 
  109.      */
  110.     private ResultSet executeQueryRS(String sql, Object[] params) {  
  111.         try {  
  112.             // 獲得連線
  113.             connnection = this.getConnection();  
  114.             // 呼叫SQL
  115.             preparedStatement = connnection.prepareStatement(sql);  
  116.             // 引數賦值
  117.             if (params != null) {  
  118.                 for (int i = 0; i < params.length; i++) {  
  119.                     preparedStatement.setObject(i + 1, params[i]);  
  120.                 }  
  121.             }  
  122.             // 執行
  123.             resultSet = preparedStatement.executeQuery();  
  124.         } catch (SQLException e) {  
  125.             System.out.println(e.getMessage());  
  126.         }  
  127.         return resultSet;  
  128.     }  
  129.     /** 
  130.      * 獲取結果集，並將結果放在List中 
  131.      *  
  132.      * @param sql 
  133.      *            SQL語句 
  134.      * @return List 
  135.      *                       結果集 
  136.      */
  137.     public List<Object> excuteQuery(String sql, Object[] params) {  
  138.         // 執行SQL獲得結果集
  139.         ResultSet rs = executeQueryRS(sql, params);  
  140.         // 建立ResultSetMetaData物件
  141.         ResultSetMetaData rsmd = null;  
  142.         // 結果集列數
  143.    

相關推薦

java（JDBC連線資料庫）[完整版封裝]

import java.sql.CallableStatement;   import java.sql.Connection;   import java.sql.DriverManager;   import java.sql.PreparedSta

jsp資料庫（一、使用jdbc連線資料庫）

步驟： 一、載入驅動程式 Class.forName("sun.jdbc.odbc.jdbcOdbcDriver"); 二、建立連線物件 Connection conn = DriverManager.getConnection("主機名","使用者名稱","密碼");

對於同一套應用程序如何發布一個體驗版（有部分功能）完整版（有完整功能）

service() () ogr com 完整 fine adk testin generic 最近項目中，先做一個版本給用戶（普通用戶作為體驗使用）。之後再有一個完整功能版。 #define OFFLINE using System; using System.

JAVA WEB JDBC連線資料庫

桂 林 理 工 大 學 實  驗  報  告 班級   軟體16-1班   學號 3162052051116  姓名 張識虔   同組實驗者     &

c#窗體之登入頁（已連線資料庫）

效果圖：   原始碼： 頁面： using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; u

Android的登入介面（未連線資料庫）

一、新增圖片 <ImageView android:id="@+id/iv" android:layout_width="70dp" android:layout_height="70dp" android:layout_centerH

java使用jdbc連線資料庫步驟

確定連線的資料庫型別《mysql，oracle，db2，moangdb，sqlservlet》 下載資料庫的驅動（http://mvnrepository.org），並把jar包新增到專案中 把資料庫連線的驅動類載入到java虛擬機器中 通過DriverManager類中ge

java通過JDBC連線資料庫及增刪改查操作

1.實戰資料庫資料的準備    建立資料庫（newsmanager），然後建立表news（id，title，content，type）和newstype（id，name），其中news的type和newstype的id為主外來鍵關係，如下圖圖   2.JDBC的介紹  

java利用jdbc連線資料庫之插入資料

java通過JDBC連線資料庫 具體功能： 使用PreparedStatement介面中的executeUpdate()方法向資料庫中插入一條資料 前提： 具有一個數據庫和一個列表（列表和資料庫長啥樣後面會說） 1：建立java project

JAVA使用JDBC連線資料庫SQL Server2012

要在JAVA中使用JDBC連線SQL Server2012資料庫需要如下三個大的步驟： 一、設定SQL Server2012的身份驗證方式為混合模式 如果不知道如何設定，請見博文： 二、啟動telnet服務 如果不知道如何啟動該服務，請見博文 三、在java中使

Java通過JDBC連線資料庫的三種方式！！！並對資料庫實現增刪改查

前言 java連線資料庫完整流程為： 1,獲得驅動(driver)，資料庫連線（url）,使用者名稱（username）,密碼（password）基本資訊的三種方式。 2,通過獲得的資訊完成JDBC實現連線資料庫。 注：連線前請匯入jar包，例：連線my

java：JDBC連線資料庫實現使用者管理系統

實現功能： 1.普通使用者註冊，登入 2.管理員使用者註冊，登入 3.管理員對普通使用者的查詢，新增，修改，刪除操作 4.對3實現ID和使用者名稱的兩種操作方式 5.對以上功能實現選單化管理 6.所有使用者資訊都儲存於Oracle資料庫 流程圖： 部分效果

java jdbc連線資料庫（使用mysql進行連線）

一、JDBC簡介 Java 資料庫連線，（Java Database Connectivity，簡稱JDBC）是Java語言中用來規範客戶端程式如何來訪問資料庫的應用程式介面，提供了諸如查詢和更新資料庫中資料的方法。JDBC也是Sun Microsystems的商標。它JD

Java 的動態代理例項（JDBC的資料庫的連線池(DataSource)）

問題：以下兩種方式的區別是什麼？ //註冊資料庫的驅動 Class.forName(driver); //還有一種方式 //DriverManager.registerDriver(new com.mysql.jdbc.Driver()); ==============

阿里雲 Linux（CentOS）中MySQL5.7安裝配置以及遠端連線配置最新完整版

1， mysql57-community-release-el7-11.noarch.rpm 點選下載並上傳到阿里雲。 2，切換資料夾，然後一步步輸入下面三條命令，即安裝好的MySQL的 （1），rpm -ivh mysql57-community-release-el7-1

JDBC連線資料庫（以mysql為例）

步驟： 1、在專案裡面配置驅動（右擊專案->built path->configure built path->libraries->add External JARs...)，新增資料庫的驅動jar包（本例mysql驅動包v5.0.8）網上下載驅動

【J2EE】【2.JDBC】JDBC連線資料庫（MariaDB，Mysql）（繼續之前jee的登陸例子）

零，名詞解釋 JDBC JDBC（Java Data Base Connectivity,java資料庫連線）是一種用於執行SQL語句的Java API，可以為多種關係資料庫提供統一訪問，它由一組用Java語言編寫的類和介面組成。JDBC提供了一種基準，據此可以構建更高階的

java之對JDBC的完整封裝（相容多種資料庫）

目前此程式碼我只用過mysql和oracle資料庫測試過，但相信其它資料庫都是可以的，只要匯入你需要操作的資料庫jar包，驅動等就可，下面上程式碼： import java.sql.CallableStatement; import java.sql.Connection

JDBC連線資料庫程式碼 （一） -- 一個簡單的獲取資料庫表單

package com.nenu.www; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql

JDBC連線資料庫之從結果集中獲取物件（3）

測試利用反射返回List物件的資料。 public <T> List<T> getForList(Class<T> clazz, String sql, Object... args) { List<T> l