bl双性强迫侵犯h_国产在线观看人成激情视频_蜜芽188_被诱拐的少孩全彩啪啪漫画

java中JDBC如何封裝兼容多種數據庫

小編給大家分享一下java中JDBC如何封裝兼容多種數據庫，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

成都創新互聯擁有一支富有激情的企業網站制作團隊，在互聯網網站建設行業深耕十多年，專業且經驗豐富。十多年網站優化營銷經驗，我們已為超過千家中小企業提供了網站設計、成都做網站解決方案，按需設計網站，設計滿意，售后服務無憂。所有客戶皆提供一年免費網站維護!

目前此代碼我只用過MySQL和oracle數據庫測試過，但相信其它數據庫都是可以的，只要導入你需要操作的數據庫jar包，驅動等就可，下面上代碼：

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
/**
 * 對jdbc的完整封裝
 *
 */
public class JDBCUtil {
 
	private static String driver = null;
	private static String url = null;
	private static String username = null;
	private static String password = null;
	
	private CallableStatement callableStatement = null;//創建CallableStatement對象   
	private Connection conn = null;
	private PreparedStatement pst = null;
	private ResultSet rst = null;
	
/*	static {  
    try {  
      // 加載數據庫驅動程序  
      Class.forName(driver);  
    } catch (ClassNotFoundException e) {  
      System.out.println("加載驅動錯誤");  
      System.out.println(e.getMessage());  
    }  
  } */  
  
	public JDBCUtil(String driver,String url ,String username,String password) {
		this.driver = driver;
		this.url = url;
		this.username = username;
		this.password = password;
	}
	
  /** 
   * 建立數據庫連接 
   * @return 數據庫連接 
   */  
  public Connection getConnection() {  
    try {  
    	 // 加載數據庫驅動程序  
      try {
				Class.forName(driver);
			} catch (ClassNotFoundException e) {
				System.out.println("加載驅動錯誤");  
	      System.out.println(e.getMessage()); 
				e.printStackTrace();
			} 
      // 獲取連接  
    	conn = DriverManager.getConnection(url, username,  
    			password);  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    }  
    return conn;  
  }  
  
  /** 
   * insert update delete SQL語句的執行的統一方法 
   * @param sql SQL語句 
   * @param params 參數數組，若沒有參數則為null 
   * @return 受影響的行數 
   */  
  public int executeUpdate(String sql, Object[] params) {  
    // 受影響的行數  
    int affectedLine = 0;  
      
    try {  
      // 獲得連接  
      conn = this.getConnection();  
      // 調用SQL   
      pst = conn.prepareStatement(sql);  
        
      // 參數賦值  
      if (params != null) {  
        for (int i = 0; i < params.length; i++) {  
        	pst.setObject(i + 1, params[i]);  
        }  
      }  
      /*在此 PreparedStatement 對象中執行 SQL 語句，
                     該語句必須是一個 SQL 數據操作語言（Data Manipulation Language，DML）語句，比如 INSERT、UPDATE 或 DELETE 
                     語句；或者是無返回內容的 SQL 語句，比如 DDL 語句。  */
      // 執行  
      affectedLine = pst.executeUpdate();
  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      // 釋放資源  
      closeAll();  
    }  
    return affectedLine;  
  }  
  
  /** 
   * SQL 查詢將查詢結果直接放入ResultSet中 
   * @param sql SQL語句 
   * @param params 參數數組，若沒有參數則為null 
   * @return 結果集 
   */  
  private ResultSet executeQueryRS(String sql, Object[] params) {  
    try {  
      // 獲得連接  
      conn = this.getConnection();  
        
      // 調用SQL  
      pst = conn.prepareStatement(sql);  
        
      // 參數賦值  
      if (params != null) {  
        for (int i = 0; i < params.length; i++) {  
        	pst.setObject(i + 1, params[i]);  
        }  
      }  
        
      // 執行  
      rst = pst.executeQuery();  
  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    }   
  
    return rst;  
  }  
    
  /** 
   * SQL 查詢將查詢結果：一行一列 
   * @param sql SQL語句 
   * @param params 參數數組，若沒有參數則為null 
   * @return 結果集 
   */  
  public Object executeQuerySingle(String sql, Object[] params) {  
    Object object = null;  
    try {  
      // 獲得連接  
      conn = this.getConnection();  
        
      // 調用SQL  
      pst = conn.prepareStatement(sql);  
        
      // 參數賦值  
      if (params != null) {  
        for (int i = 0; i < params.length; i++) {  
        	pst.setObject(i + 1, params[i]);  
        }  
      }  
        
      // 執行  
      rst = pst.executeQuery();  
  
      if(rst.next()) {  
        object = rst.getObject(1);  
      }  
        
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      closeAll();  
    }  
  
    return object;  
  }  
  
  /** 
   * 獲取結果集，并將結果放在List中 
   *  
   * @param sql SQL語句 
   *     params 參數，沒有則為null  
   * @return List 
   *            結果集 
   */  
  public List<Object> excuteQuery(String sql, Object[] params) {  
    // 執行SQL獲得結果集  
    ResultSet rs = executeQueryRS(sql, params);  
      
    // 創建ResultSetMetaData對象  
    ResultSetMetaData rsmd = null;  
      
    // 結果集列數  
    int columnCount = 0;  
    try {  
      rsmd = rs.getMetaData();  
        
      // 獲得結果集列數  
      columnCount = rsmd.getColumnCount();  
    } catch (SQLException e1) {  
      System.out.println(e1.getMessage());  
    }  
  
    // 創建List  
    List<Object> list = new ArrayList<Object>();  
  
    try {  
      // 將ResultSet的結果保存到List中  
      while (rs.next()) {  
        Map<String, Object> map = new HashMap<String, Object>();  
        for (int i = 1; i <= columnCount; i++) {  
          map.put(rsmd.getColumnLabel(i), rs.getObject(i));  
        }  
        list.add(map);//每一個map代表一條記錄，把所有記錄存在list中  
      }  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      // 關閉所有資源  
      closeAll();  
    }  
  
    return list;  
  }  
    
  /** 
   * 存儲過程帶有一個輸出參數的方法 
   * @param sql 存儲過程語句 
   * @param params 參數數組 
   * @param outParamPos 輸出參數位置 
   * @param SqlType 輸出參數類型 
   * @return 輸出參數的值 
   */  
  public Object excuteQuery(String sql, Object[] params,int outParamPos, int SqlType) {  
    Object object = null;  
    conn = this.getConnection();  
    try {  
      // 調用存儲過程  
    	// prepareCall:創建一個 CallableStatement 對象來調用數據庫存儲過程。
      callableStatement = conn.prepareCall(sql);  
        
      // 給參數賦值  
      if(params != null) {  
        for(int i = 0; i < params.length; i++) {  
          callableStatement.setObject(i + 1, params[i]);  
        }  
      }  
        
      // 注冊輸出參數  
      callableStatement.registerOutParameter(outParamPos, SqlType);  
        
      // 執行  
      callableStatement.execute();  
        
      // 得到輸出參數  
      object = callableStatement.getObject(outParamPos);  
        
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      // 釋放資源  
      closeAll();  
    }  
      
    return object;  
  }  
  
  /** 
   * 關閉所有資源 
   */  
  private void closeAll() {  
    // 關閉結果集對象  
    if (rst != null) {  
      try {  
        rst.close();  
      } catch (SQLException e) {  
        System.out.println(e.getMessage());  
      }  
    }  
  
    // 關閉PreparedStatement對象  
    if (pst != null) {  
      try {  
        pst.close();  
      } catch (SQLException e) {  
        System.out.println(e.getMessage());  
      }  
    }  
      
    // 關閉CallableStatement 對象  
    if (callableStatement != null) {  
      try {  
        callableStatement.close();  
      } catch (SQLException e) {  
        System.out.println(e.getMessage());  
      }  
    }  
  
    // 關閉Connection 對象  
    if (conn != null) {  
      try {  
        conn.close();  
      } catch (SQLException e) {  
        System.out.println(e.getMessage());  
      }  
    }    
  }  
}

使用的時候直接new一個JDBCUtil類，然后對傳入對應的sql語句，例：

public class JDBCTest {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		JDBCUtil jdbcUtil = new JDBCUtil("com.mysql.jdbc.Driver",
		"jdbc:mysql://localhost:3306/myhelp?useUnicode=true&characterEncoding=utf-8&useSSL=false","root","142014068");
		String sql = "delete from menu_detial where count=6";
		System.out.println(jdbcUtil.executeUpdate(sql, null));
	}
}

以上是“java中JDBC如何封裝兼容多種數據庫”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注創新互聯行業資訊頻道！

分享文章：java中JDBC如何封裝兼容多種數據庫
網頁鏈接：http://vcdvsql.cn/article0/gjihio.html

成都網站建設公司_創新互聯，為您提供品牌網站設計、網站建設、網站設計公司、微信公眾號、外貿建站、品牌網站制作

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯

手機網站建設