這篇文章主要介紹瞭如何使用JDBC實現工具類抽取,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

1、JDBC工具類抽取

上一篇做了JDBC的基本操作，但是獲取連線及釋放資源是比較重複的操作，可以抽取工具類而達到程式碼重用的目的
工程結構如圖

JDBC工具類程式碼

db.properties

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://192.168.47.151:3306/web?useUnicode=true&characterEncoding=utf8
username=root
password=root

JDBCUtils.java

package com.rookie.bigdata.util;

import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
import java.util.ResourceBundle;

/**
 * Created by dell on 2019/5/22.
 */
package com.rookie.bigdata.util;

import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
import java.util.ResourceBundle;

/**
 * Created by dell on 2019/5/22.
 */
public class JDBCUtils {

  private static String driver;
  private static String url;
  private static String username;
  private static String password;

  //  //靜態程式碼塊載入配置檔案資訊
//  static {
//    ResourceBundle db = ResourceBundle.getBundle("db");
//    driver = db.getString("driver");
//    url = db.getString("url");
//    username = db.getString("username");
//    password = db.getString("password");
//  }
  //靜態程式碼塊載入配置檔案資訊
  static {
    try {
      //獲取類載入器
      ClassLoader classLoader = JDBCUtils.class.getClassLoader();
      //通過類載入器的方法獲取一個輸入流
      InputStream resourceAsStream = classLoader.getResourceAsStream("db.properties");
      Properties properties = new Properties();
      properties.load(resourceAsStream);
      //獲取相關引數的值
      driver = properties.getProperty("driver");
      url = properties.getProperty("url");
      username = properties.getProperty("username");
      password = properties.getProperty("password");
    } catch (Exception e) {
      e.printStackTrace();
    }

  }


  /**
   * 獲取連線
   *
   * @return
   */
  public static Connection getConnection() {

    Connection conn = null;
    try {
      Class.forName(driver);
      conn = DriverManager.getConnection(url,username,password);
    } catch (Exception e) {
      e.printStackTrace();
    }
    return conn;
  }

  /**
   * 釋放資源
   * @param conn
   * @param pstmt
   * @param rs
   */
  public static void relase(Connection conn,PreparedStatement pstmt,ResultSet rs) {
    if (rs != null) {
      try {
        rs.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    if (pstmt != null) {
      try {
        pstmt.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    if (conn != null) {
      try {
        conn.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }

  }
}

2、批量插入資料

package com.rookie.bigdata;

import com.rookie.bigdata.util.JDBCUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;

/**
 * CREATE TABLE `user` (
 * `USERNAME` varchar(30) DEFAULT NULL COMMENT '使用者名稱',* `PASSWORD` varchar(10) DEFAULT NULL COMMENT '密碼'
 * ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 */
public class JDBCBatch {
  public static void main(String[] args) throws Exception {
    Connection connection = JDBCUtils.getConnection();
    //設定自動提交關閉
    connection.setAutoCommit(false);
    PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO USER VALUES (?,?)");

    for (int i = 1; i <= 5000; i++) {
      preparedStatement.setString(1,"張三" + i);
      preparedStatement.setString(2,"123" + i);
      preparedStatement.addBatch();
      if (i % 1000 == 0) {
        preparedStatement.executeUpdate();
        connection.commit();
        preparedStatement.clearBatch();
      }
    }
    preparedStatement.executeUpdate();
    connection.commit();
    preparedStatement.clearBatch();

  }
}

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。