opindex.java

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

import java.sql.*;
import java.net.URL;

class opindex{
public static void main (String args[]) {
String url="jdbc:microsoft:sqlserver://localhost:1433;User=JavaDB;Password=javadb;DatabaseName=northwind";
	String query1= "CREATE INDEX index1 on javadb.FirstTable(ID,name)";
	String query2= "CREATE INDEX index2 on javadb.FirstTable(name)";
	try {
		//加载驱动程序
		Class.forName ("com.microsoft.jdbc.sqlserver.SQLServerDriver");
		Connection con = DriverManager.getConnection (url);
		DatabaseMetaData dbmd = con.getMetaData();

		//建立一个Statement对象,用这个对象向驱动程序发送SQL语句
		Statement stmt = con.createStatement ();

		//创建索引
		stmt.executeUpdate(query1);
		stmt.executeUpdate(query2);
		
		//显示数据库的索引
		System.out.println("show all the indics in the database:");
		displayMetadata(dbmd);
		
		// 关闭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 ();
	}
}
//显示数据库元数据
private static void displayMetadata(DatabaseMetaData dbmd)
{
	String view[] = {"VIEW"};
	try
	{
		ResultSet rset =dbmd.getIndexInfo(null,null,"FirstTable",false,true);
		while(rset.next())
	{
		System.out.print(rset.getString("INDEX_NAME") + "---");
		System.out.print(rset.getString("TYPE") + "---");
		System.out.println(rset.getString("COLUMN_NAME"));
	}
	System.out.println("");
	rset.close();
	}
	catch(Exception e)
	{
		System.out.println("error");
	}
}
}