java2sqlserver.java

本套光盘提供了本书各章实例的所需的部分源程序文件以及数据库文件。读者 需要使用JDK 1.4(必需）版

//import com.microsoft.*;
import java.sql.*;
import java.net.URL;

class java2sqlserver {

public static void main (String args[]) {
	String url   = "jdbc:microsoft:sqlserver://localhost:1433;User=JavaDB;Password=javadb;DatabaseName=northwind";
	String query = "SELECT * FROM Categories"; 

	try {

		// Load the jdbc-odbc bridge driver

		Class.forName ("com.microsoft.jdbc.sqlserver.SQLServerDriver");
		//设置跟踪JDBC执行过程的纪录流
		//DriverManager.setLogStream(System.out);

		// // 连接到驱动程序。系统中已经注册的驱动程序，将会被依次进行装载和连接，
		//直到找到一个正确的驱动程序为止。		

		
		Connection con = DriverManager.getConnection (
			url);

		// 如果无法获得连接，陈旭辉抛出一个异常，所以如果程序已经执行
		//到这里，说明已经连接成功

		// 检查和显示在连接过程中出现的错误和警告信息
		checkForWarning (con.getWarnings ());

		// 建立一个Statement对象，用这个对象向驱动程序发送SQL语句

		Statement stmt = con.createStatement ();

		// 提交SQL语句，创建一个ResultSet对象

		ResultSet rs = stmt.executeQuery (query);

		// 显示结果集的所有行和列
		dispResultSet (rs);

		// 关闭结果集
		rs.close();

		// 关闭statement对象
		stmt.close();

		// 关闭连接
		con.close();

	}
	catch (SQLException ex) {

		// 捕获错误信息，并显示其详细信息

	System.out.println ("\n*** SQLException caught ***\n");

	while (ex != null) {
		System.out.println ("SQLState: " +
				ex.getSQLState ());
		System.out.println ("Message:  " + ex.getMessage ());
		System.out.println ("Vendor:   " +
				ex.getErrorCode ());
		ex = ex.getNextException ();
		System.out.println ("");
		}
	}
	catch (java.lang.Exception ex) {

		// 捕获其他类型的例外.

		ex.printStackTrace ();
	}
}

//-------------------------------------------------------------------
// checkForWarning
// 检查是否在SQL对象执行过程中出现了警告等错误信息
//如果有的话将显示出来
//-------------------------------------------------------------------

private static boolean checkForWarning (SQLWarning warn) 	
		throws SQLException  {
	boolean rc = false;

	// If a SQLWarning object was given, display the
	// warning messages.  Note that there could be
	// multiple warnings chained together

	if (warn != null) {
		System.out.println ("\n *** Warning ***\n");
		rc = true;
		while (warn != null) {
			System.out.println ("SQLState: " +
				warn.getSQLState ());
			System.out.println ("Message:  " +
				warn.getMessage ());
			System.out.println ("Vendor:   " +
				warn.getErrorCode ());
			System.out.println ("");
			warn = warn.getNextWarning ();
		}
	}
	return rc;
}

//-------------------------------------------------------------------
// dispResultSet
// 现实整个结果届中的所有的行和列
//-------------------------------------------------------------------

private static void dispResultSet (ResultSet rs)
	throws SQLException
{
	int i;

	// // 取得结果集的元数据

	ResultSetMetaData rsmd = rs.getMetaData ();

	// 获得结果集的列数

	int numCols = rsmd.getColumnCount ();

	// 显示列的标题

	for (i=1; i<=numCols; i++) {
		if (i > 1) System.out.print(",");
		System.out.print(rsmd.getColumnLabel(i));
	}
	System.out.println("");
	
	// 显示结果集中所有数据

	boolean more = rs.next ();
	while (more) {

		// // 循环显示结果集中的所有数据

		for (i=1; i<=numCols; i++) {
			if (i > 1) System.out.print(",");
			System.out.print(rs.getString(i));
		}
		System.out.println("");

		// Fetch the next result set row

		more = rs.next ();
	}
}

}