databaseconnection.java

java程序设计教程的源码

/*【例12-1】  创建一个以JDBC-ODBC和纯Java的第三方JDBC驱动程序方式连接
 *MS SQL Server 2000和Oracle等各种不同类型数据库的连接工具类
 *db.connection.DatabaseConnection。 
 */
//程序清单12-1:  DatabaseConnection.java
package db.connection;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseConnection {
// ①连接Microsoft SQL Server 2000数据库
  public Connection getMsSqlServerConnection(String DatabaseName, String User, String Password) {
  	Connection con = null;
	// 声明JDBC驱动程序类型
	String JDBCDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
	// 定义JDBC的URL对象
	String conURL = "jdbc:microsoft:sqlserver://127.0.0.1:1433;"
				+ "DatabaseName=" + DatabaseName + ";User=" + User
				+ ";Password=" + Password;
		try {Class.forName(JDBCDriver);
		} catch (ClassNotFoundException e) {
			System.out.println("Class.forname:" + e.getMessage());
		}
		try {con = DriverManager.getConnection(conURL);
		} catch (SQLException e) {
			System.out.println("=SQLException:" + e.getMessage());
		}
		return con;
	}
// ②连接MySQL数据库
	public Connection getMySqlConnection(String DatabaseName, String User,String Password) {
	Connection con = null;
	// 声明JDBC驱动程序类型
	String JDBCDriver = "com.mysql.jdbc.Driver";
	// 定义JDBC的URL对象
	String conURL = "jdbc:mysql://127.0.0.1:3306/" + DatabaseName
				+ "?user=" + User + "root&password=" + Password;
	try {Class.forName(JDBCDriver);
		} catch (ClassNotFoundException e) {
		System.out.println("Class.forname:" + e.getMessage());
		}
	try {con = DriverManager.getConnection(conURL);
		} catch (SQLException e) {
		System.out.println("=SQLException:" + e.getMessage());
		}
	return con;
	}
// ③连接Oracle 9i数据库
public Connection getOracleConnection(String ServerName, String port, String Database, String User, String Password) {
	Connection con = null;
	// 声明JDBC驱动程序类型
	String JDBCDriver = "oracle.jdbc.driver.OracleDriver";
	// 定义JDBC的URL对象
	String conURL = "jabc:oracle:thin:@" + ServerName + ":" + port + ":" + Database;
		try {	Class.forName(JDBCDriver);
		} catch (ClassNotFoundException e) {
		System.out.println("Class.forname:" + e.getMessage());
		}
		try {// 连接数据库URL
		con = DriverManager.getConnection(conURL, User, Password);
		} catch (SQLException e) {
		System.out.println("=SQLException:" + e.getMessage());
	}
	return con;
	}
// ④连接DB2数据库
public Connection getDB2Connection(String ServerName, String port, String Database) {
		Connection con = null;
		// 声明JDBC驱动程序类型
		String JDBCDriver = "com.ibm.db2.jcc.DB2Driver";
		// 定义JDBC的URL对象
	      String conURL = "jdbc:db2://" + ServerName + ":" + port + "/" + Database;
		try {Class.forName(JDBCDriver);
		} catch (ClassNotFoundException e) {
			System.out.println("Class.forname:" + e.getMessage());
		}
		try {con = DriverManager.getConnection(conURL);
		} catch (SQLException e) {
			System.out.println("=SQLException:" + e.getMessage());
		}
		return con;
	}
// ⑤通过JDBC-ODBC桥连接各种ODBC的DSN数据源
	public Connection getJDBCODBCConnection(String DatabaseDSN) {
		Connection con = null;
		// 声明JDBC驱动程序类型
		String JDBCDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
		// 定义JDBC的URL对象
		String conURL = "jdbc:odbc:" + DatabaseDSN;
		try {
			Class.forName(JDBCDriver);
		} catch (ClassNotFoundException e) {
			System.out.println("Class.forname:" + e.getMessage());
		}
		try {
			con = DriverManager.getConnection(conURL);
		} catch (SQLException e) {
			System.out.println("=SQLException:" + e.getMessage());
		}
		return con;
	}
}