java連接SqlServer2008的數(shù)據(jù)庫連接池使用:
專注于為中小企業(yè)提供網(wǎng)站建設(shè)、做網(wǎng)站服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)順平免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都,凝聚了一批互聯(lián)網(wǎng)行業(yè)人才,有力地推動了近千家企業(yè)的穩(wěn)健成長,幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Vector;
/**數(shù)據(jù)庫連接池的公共類 **/
public class ConnectionPool {
private VectorConnection pool;//聲明集合,里面只能是放Connection
/**
* 聲明要的東西
*/
private String url = "jdbc:sqlserver://localhost:1433; database=ajax";
private String username = "sa";
private String password = "sa123";
private String driverClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
/**
* 連接池的大小,也就是連接池中有多少個數(shù)據(jù)庫連接
*/
private int poolSize = 5;
private static ConnectionPool instance = null;
/**
* 私有的構(gòu)造方法,禁止外部創(chuàng)建本類的對象,要想獲得本類的對象,通過codegetIstance/code方法
* 使用了設(shè)計(jì)模式中的單子模式
*/
private ConnectionPool() {
init();
}
/**
* 連接池初始化方法,讀取屬性文件的內(nèi)容 建立連接池中的初始連
*/
private void init() {
pool = new VectorConnection(poolSize);
//readConfig();
addConnection();
}
/**
* 返回連接到連接池
*/
public synchronized void release(Connection conn) {
pool.add(conn);
}
/**
* 關(guān)閉連接池中的所有數(shù)據(jù)庫連接
*/
public synchronized void closePool() {
for (int i = 0; i pool.size(); i++) {
try {
((Connection) pool.get(i)).close();
} catch (SQLException e) {
e.printStackTrace();
}
pool.remove(i);
}
}
/**
* 返回當(dāng)前連接池的對象
*/
public static ConnectionPool getInstance() {
if (instance == null) {
instance = new ConnectionPool();
}
return instance;
}
/**
* 返回連接池中的一個數(shù)據(jù)庫連接
*/
public synchronized Connection getConnection() {
if (pool.size() 0) {
Connection conn = pool.get(0);
pool.remove(conn);
return conn;
} else {
return null;
}
}
/**
* 在連接池中創(chuàng)建初始設(shè)置的的數(shù)據(jù)庫連接
*/
private void addConnection() {
Connection conn = null;
for (int i = 0; i poolSize; i++) {
try {
Class.forName(driverClassName);
conn = java.sql.DriverManager.getConnection(url, username,
password);
pool.add(conn);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
1、 安裝時區(qū)別:
與mysql相比,Sqlserver安裝后,的配置TCP/IP協(xié)議,Sql Server 身份注冊登錄 ,都比較麻煩。
2、配置連接時區(qū)別:
mysql
使用的驅(qū)動:com.mysql.jdbc.Driver
依賴包:mysql 可以直接通過pom.xml下載
sqlserver驅(qū)動:com.microsoft.sqlserver.jdbc.SQLServerDriver
依賴包:sqljdbc4 需要從本地置入
sqlserver2000與2005的jar文件不一樣。
驅(qū)動類,還有連接語句都不一樣。
驅(qū)動類:
com.microsoft.jdbc.sqlserver.SQLServerDriver(sqlserver2000)
com.microsoft.sqlserver.jdbc.SQLServerDriver(sqlserver2005)
連接語句:
jdbc:microsoft:sqlserver://server_name:1433 (sqlserver2000)
jdbc:sqlserver://server_name:1433[;databaseName=dbname] (sqlserver2005)
如果都沒有錯可能是
java.lang.ClassNotFoundException: com.microsoft.jdbc.sqlserver.SQLSerDriver
中指出的你寫的SQLSerDriver把它改成SQLServerDriver
從M$網(wǎng)站下載最新JDBC驅(qū)動或都使用maven:
dependency
groupIdcom.microsoft.sqlserver/groupId
artifactIdmssql-jdbc/artifactId
version9.4.1.jre11/version
/dependency
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
public class SQLDatabaseConnection {
// Connect to your database.
// Replace server name, username, and password with your credentials
public static void main(String[] args) {
String connectionUrl =
"jdbc:sqlserver://yourserver.database.windows.net:1433;"
+ "database=AdventureWorks;"
+ "user=yourusername@yourserver;"
+ "password=yourpassword;"
+ "encrypt=true;"
+ "trustServerCertificate=false;"
+ "loginTimeout=30;";
String insertSql = "INSERT INTO SalesLT.Product (Name, ProductNumber, Color, StandardCost, ListPrice, SellStartDate) VALUES "
+ "('NewBike', 'BikeNew', 'Blue', 50, 120, '2016-01-01');";
ResultSet resultSet = null;
try (Connection connection = DriverManager.getConnection(connectionUrl);
PreparedStatement prepsInsertProduct = connection.prepareStatement(insertSql, Statement.RETURN_GENERATED_KEYS);) {
prepsInsertProduct.execute();
// Retrieve the generated key from the insert.
resultSet = prepsInsertProduct.getGeneratedKeys();
// Print the ID of the inserted row.
while (resultSet.next()) {
System.out.println("Generated: " + resultSet.getString(1));
}
}
// Handle any errors that may have occurred.
catch (Exception e) {
e.printStackTrace();
}
}
}