datamainclass.java

jbuilder2006一书的所有源代码

package rmi;

import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.RMISecurityManager;
import java.rmi.server.UnicastRemoteObject;
import java.sql.*;

//引用远程接口文件DataRemote
public class DataMainClass extends UnicastRemoteObject implements DataRemote {

  public DataMainClass() throws RemoteException {
    super();
  }
  //取得bookcategory数据表的记录
  public String[][] getBookCategory() {
    String[][] result = null;
    String driver = "org.gjt.mm.mysql.Driver";
    String url = "jdbc:mysql://localhost:3306/books?user=root;password=";
    Connection conn = null;
    try{
      Class.forName(driver);
      conn = DriverManager.getConnection(url, "", "");
      Statement stmt = conn.createStatement();
      //取得记录总数
      ResultSet rs = stmt.executeQuery("select count(*) from bookcategory");
      if(rs.next()){
        int count = rs.getInt(1);
        //根据记录总数创建数组
        result = new String[count][3];
      }
      //取得记录
      rs = stmt.executeQuery("select * from bookcategory");
      int i = 0;
      while(rs.next()){
        result[i][0] = rs.getString(1);
        result[i][1] = rs.getString(2);
        result[i][2] = rs.getString(3);
        i++;
      }
    }catch(Exception ex){
      ex.printStackTrace();
    }
    try{
      //关闭数据库连接类
      conn.close();
    }catch(Exception ex){
      ex.printStackTrace();
    }
    //返回数组
    return result;
  }
  public static void main(String args[]) {
    //加入安全机制类
    if (System.getSecurityManager() == null) {
      System.setSecurityManager(new RMISecurityManager());
    }
    try {
      //创建服务器对象
      DataMainClass obj = new DataMainClass();
      //在register注册该对象，localhost是服务器的名字
      Naming.rebind("//localhost/Data", obj);
      System.out.println("服务端的DataMainClass已注册！");
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}