java2access.java

来自「本套光盘提供了本书各章实例的所需的部分源程序文件以及数据库文件。读者 需要使用」· Java 代码 · 共 83 行

import java.sql.*;
public class java2Access
{ 
	public static void main( String[] args)
	{
		String DBDriver = "sun.jdbc.odbc.JdbcOdbcDriver"; 
		String connectionStr = "jdbc:odbc:IProducts";
		Connection connection = null; 
		String sql = "Select * From Products where CatalogID='002'";
		ResultSet rs = null;
		Statement statement = null;
		try 
		{ 
			//加载数据库驱动程序 
			Class.forName(DBDriver);
		} 
		catch(java.lang.ClassNotFoundException e) 
		{
			System.err.println("DBconnection(): " + e.getMessage());
		}

		try 
		{ 
			//与DBMS建立链接 
			connection = DriverManager.getConnection(connectionStr,"",""); 

			//创建Statement对象
			statement = connection.createStatement();

			//执行查询操作
			rs  = statement.executeQuery(sql); 
			if(rs!=null)
			{
				ResultSetMetaData rsmd = rs.getMetaData ();

				// Get the number of columns in the result set

				int numCols = rsmd.getColumnCount();

				// Display column headings

				for (int i=1; i<=numCols; i++) 
				{
					if (i > 1) System.out.print(",     ");
					System.out.print(rsmd.getColumnLabel(i));
				}
				System.out.println("");
				System.out.println("");
				while(rs.next())
				{ 
					//显示结果
					System.out.print(rs.getString("ProductName")+"---"); 
					System.out.print(rs.getString("ProductPrice")+"---");  
					System.out.println(rs.getString(5));
				} 
			}
		} 
		catch(SQLException ex) 
		{
			System.err.println("aq.executeQuery:"+ ex.getMessage()); 
		}
 
		finally
		{
			//关闭对象
			try
			{
				if(rs!= null) 
					rs.close();
	
				if(statement != null)
					statement.close();

				if(connection != null)
					connection.close();
			}
			catch(SQLException sqlerror)
			{
				sqlerror.printStackTrace();
			}
		} 
	}
}