import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
/**
* 连接各类数据库的方法
*/
public class DBConnector {
/**
* 获得数据库连接
*
* @param driverClassName
* 连接数据库用到的驱动类的类名
* @param dbURL
* 数据库的URL
* @param userName
* 登陆数据库的用户名
* @param password
* 登陆数据库的密码
* @return
* @throws ClassNotFoundException
* @throws SQLException
*/
// 加载连接数据库的驱动类
Class.forName(driverClassName);
// 用用户名、密码连接数据库
return con;
}
/**
* 获得Oracle数据库的连接
*
* @param dricerClassName
* 连接数据库用到的驱动类的类名
* @param serverHost
* 数据库所在服务器的IP或域名
* @param serverPort
* 数据库所在服务器的端口
* @param dbName
* 数据库名
* @param userName
* 登陆数据库的用户名
* @param password
* 登陆数据库的密码
* @return
* @throws ClassNotFoundException
* 数据库驱动类无法找到是抛出该异常
* @throws SQLException
* 创建连接时可能抛出该异常
*/
// 如果没有提供这些连接参数,则用默认值
if (dricerClassName == null) {
dricerClassName = "oracle.jdbc.driver.OracleDriver";
}
if (serverHost == null) {
serverHost = "127.0.0.1";
}
if (serverPort == null) {
serverPort = "1521";
}
// 构建访问Oracle数据库的URL
String dbURL
= "jdbc:oracle:thin:@" + serverHost
+ ":" + serverPort
+ ":" + dbName;
return getConnection(dricerClassName, dbURL, userName, password);
}
/**
* 获得DB2数据库的连接
*/
// 如果没有提供这些连接参数,则用默认值
if (dricerClassName == null) {
dricerClassName = "com.ibm.db2.jdbc.app.DB2Driver";
}
if (serverHost == null) {
serverHost = "127.0.0.1";
}
if (serverPort == null) {
serverPort = "5000";
}
// 构建访问DB2数据库的URL
String dbURL
= "jdbc:db2://" + serverHost
+ ":" + serverPort
+ "/"
+ dbName;
return getConnection(dricerClassName, dbURL, userName, password);
}
/**
* 获得SQL Server数据库的连接
*/
// 如果没有提供这些连接参数,则用默认值
if (dricerClassName == null) {
dricerClassName = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
}
if (serverHost == null) {
serverHost = "127.0.0.1";
}
if (serverPort == null) {
serverPort = "1433";
}
// 构建访问SQL Server数据库的URL
String dbURL
= "jdbc:microsoft:sqlserver://" + serverHost
+ ":"
+ serverPort + "; DatabaseName=" + dbName;
return getConnection(dricerClassName, dbURL, userName, password);
}
/**
* 获得MySQL数据库的连接
*/
// 如果没有提供这些连接参数,则用默认值
if (dricerClassName == null) {
dricerClassName = "com.mysql.jdbc.Driver";
}
if (serverHost == null) {
serverHost = "127.0.0.1";
}
if (serverPort == null) {
serverPort = "3306";
}
// 构建访问SQL Server数据库的URL
String dbURL
= "jdbc:mysql://" + serverHost
+ ":" + serverPort
+ "/"
+ dbName;
return getConnection(dricerClassName, dbURL, userName, password);
}
/**
* 获得Sybase数据库的连接
*/
// 如果没有提供这些连接参数,则用默认值
if (dricerClassName == null) {
dricerClassName = "com.sybase.jdbc3.jdbc.SybDriver";
}
if (serverHost == null) {
serverHost = "127.0.0.1";
}
if (serverPort == null) {
serverPort = "5007";
}
// 构建访问SQL Server数据库的URL
String dbURL
= "jdbc:sybase:Tds:" + serverHost
+ ":" + serverPort
+ "/"
+ dbName;
return getConnection(dricerClassName, dbURL, userName, password);
}
/**
* 获得PostgreSQL数据库的连接
*/
// 如果没有提供这些连接参数,则用默认值
if (dricerClassName == null) {
dricerClassName = "org.postgresql.Driver";
}
if (serverHost == null) {
serverHost = "127.0.0.1";
}
if (serverPort == null) {
serverPort = "5432";
}
// 构建访问SQL Server数据库的URL
String dbURL
= "jdbc:postgresql://" + serverHost
+ ":" + serverPort
+ "/" + dbName;
return getConnection(dricerClassName, dbURL, userName, password);
}
// 获得本地MySQL的连接实例,使用MySQL需要去www.mysql.com下载最新的MySQL安装程序和Java驱动
// MySQL有多个连接MySQL的驱动类,如org.gjt.mm.mysql.Driver。
// 这里使用MySQL官方网站上提供的驱动类
String mySQLDirver
= "com.mysql.jdbc.Driver";
Connection con
= DBConnector.
getMySQLConnection(mySQLDirver,
null,
null, dbName, userName, password);
System.
out.
println("连接MySQL数据库成功!");
con.close();
System.
out.
println("成功关闭与MySQL数据库的连接!");
String url
= "jdbc:mysql://127.0.0.1:3306/" + dbName
;
con = DBConnector.getConnection(mySQLDirver, url, userName, password);
System.
out.
println("连接MySQL数据库成功!");
con.close();
System.
out.
println("成功关闭与MySQL数据库的连接!");
}
}