remimpl.java

来自「有关java的源程序,为讲授java程序设计课程使用」· Java 代码 · 共 127 行

import java.rmi.*;
import java.rmi.server.UnicastRemoteObject;
import java.sql.*;
import java.io.*;

public class RemImpl extends UnicastRemoteObject implements Rem
{
   public RemImpl() throws RemoteException
   {
      super();
   }
   public void StatementExecSQLSelect() throws RemoteException
   {
            try
            {
//URL Format: "jdbc:odbc:Data Source Name",  DSN不区分大小写
                String url="jdbc:odbc:studlist";
                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
/*
In SQL Server:
                Connection con=DriverManager.getConnection(url,"yanguser","1234");
In Microsoft Access:
                Connection con=DriverManager.getConnection(url,"","");
*/
                Connection con=DriverManager.getConnection(url,"yanguser","1234");
//Get Data Base Basica Information
				System.out.println("\nData Base Basica Information");
                DatabaseMetaData dma=con.getMetaData();
				System.out.println("URL String:"+dma.getURL());
                System.out.println("Driver Name:"+dma.getDriverName());
                System.out.println("Driver Version:"+dma.getDriverVersion());
				System.out.println("Driver Major Version:"+dma.getDriverMajorVersion());
				System.out.println("Driver Minor Version:"+dma.getDriverMinorVersion());
				System.out.println("User Name:"+dma.getUserName());
System.out.println("Database Product Name:"+dma.getDatabaseProductName());
System.out.println("Database Product Name:"+dma.getDatabaseProductVersion());

                Statement stmt=con.createStatement();
//Execute SQLSelect 
				System.out.print("Execute SQL Select Statement\n");
                ResultSet rs=stmt.executeQuery("select * from  student");
                while(rs.next())
 	            {
// Field Name 不区分大小写
					int ID=rs.getInt("ID");
                    System.out.print("ID: "+ID+" ");		
                    String Name=rs.getString("NAME");
                    System.out.print("Name: "+Name+" ");
				    int AGE=rs.getInt("AGE");
                    System.out.println("Age: "+AGE);		

                }
				stmt.close();   //must close
                con.close();
            }
            catch(SQLException e)
            {
                   System.out.println("SQLState:"+e.getSQLState());
                   System.out.println("Message:"+e.getMessage());
                   System.out.println("Vendor:"+e.getErrorCode());
            }
            catch(ClassNotFoundException e)
            {
                   System.out.println(e);
            }
     
   }
   public void StatementExecSQLUpdateDBRecord() throws RemoteException
   {
            try
            {
//URL Format: "jdbc:odbc:Data Source Name"
                String url="jdbc:odbc:studlist";
                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
/*
In SQL Server:
                Connection con=DriverManager.getConnection(url,"yanguser","1234");
In Microsoft Access:
                Connection con=DriverManager.getConnection(url,"","");
*/
                Connection con=DriverManager.getConnection(url,"yanguser","1234");
//Get Data Base Basica Information
				System.out.println("\nData Base Basica Information");
                DatabaseMetaData dma=con.getMetaData();

				System.out.println("URL String:"+dma.getURL());
                System.out.println("Driver Name:"+dma.getDriverName());
                System.out.println("Driver Version:"+dma.getDriverVersion());
				System.out.println("Driver Major Version:"+dma.getDriverMajorVersion());
				System.out.println("Driver Minor Version:"+dma.getDriverMinorVersion());
				System.out.println("User Name:"+dma.getUserName());
System.out.println("Database Product Name:"+dma.getDatabaseProductName());
System.out.println("Database Product Name:"+dma.getDatabaseProductVersion());

                Statement stmt=con.createStatement();
//Update DB(Execute SQL update Statement)
                System.out.print("Update DateBase----StateMent.executeUpdate()\n");
		        int RecordRowNum=stmt.executeUpdate("Update student set name='yang' where id=1");
				System.out.println("The Record Row Num Is "+RecordRowNum);
                ResultSet rs=stmt.executeQuery("select * from  student");
                while(rs.next())
 	            {
		           int ID=rs.getInt("id");
                   System.out.print("ID: "+ID+" ");		
                   String Name=rs.getString("name");
                   System.out.print("Name: "+Name+" ");
				   int AGE=rs.getInt("age");
                   System.out.println("Age: "+AGE);		
                }
				stmt.close();   //must close
                con.close();
            }
            catch(SQLException e)
            {
                   System.out.println("SQLState:"+e.getSQLState());
                   System.out.println("Message:"+e.getMessage());
                   System.out.println("Vendor:"+e.getErrorCode());
            }
            catch(ClassNotFoundException e)
            {
                   System.out.println(e);
            }
	
   }

}