Một ứng dụng RMI truy xuất CSDL

Ứng dụng sau đây demo dùng RMI và truy xuất CSDL:

Chúng ta tao thư mục databaseRMI để lưu ứng dụng của mình.

Tạo interface AccessDBInterface.java có nội dung sau

import java.rmi.Remote;
import java.rmi.RemoteException;
import javax.sql.rowset.WebRowSet;

public interface AccessDBInterface extends Remote{
public WebRowSet GetTable(String tableName) throws RemoteException;
public int ExecUpdateSQL(String sql)throws RemoteException;
}

compile interface này. Sau đó tạo 2 thư mục server và client rồi copy tập tin AccessDBInterfac.class vào cả 2 thư mục đó.

====================================================

Phía Server:

1>Tạo file implements với tên AccessDBImpl.java có nội dung sau

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import javax.sql.rowset.*;
import com.sun.rowset.*;

public class AccessDBImpl extends UnicastRemoteObject implements AccessDBInterface {

private Connection con;
private Statement stmt;

public AccessDBImpl() throws RemoteException {
try {
Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver”);
con = DriverManager.getConnection(“jdbc:odbc:test”);
stmt = con.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
}

public WebRowSet GetTable(String tableName) throws RemoteException {
WebRowSet rs = null;
try {
String sql = “select * from ” + tableName;
ResultSet r = stmt.executeQuery(sql);
rs=new WebRowSetImpl();
rs.populate(r);
} catch (Exception e) {
e.printStackTrace();
}
return rs;
}

public int ExecUpdateSQL(String sql) throws RemoteException {
//int x=stmt.executeUpdate(sql);
return 0;
}
}

2>Tạo server AccessDBServer.java với nội dung sau

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.rowset.WebRowSet;

public class AccessDBServer {

public static void main(String []args){
try {
java.rmi.registry.LocateRegistry.createRegistry(1099);
AccessDBInterface acc=null;
acc=new AccessDBImpl();
Context ctx =new InitialContext();
ctx.bind(“rmi:acc”, acc);
System.out.println(“Server is running…”);

/*try {
AccessDBImpl db=new AccessDBImpl();
WebRowSet rs=db.GetTable(“DimCurrency”);
while(rs.next())
{
System.out.println(rs.getString(1));
}
}
catch (Exception ex) {
ex.printStackTrace();
}*/

} catch (Exception e) {
e.printStackTrace();
}
}
}
3> Build các file

4>Tạo file Server.bat để thực thi với nội dung sau:

java AccessDBServer

5>Runserver

Lưu ý: Ở đây sử dụng 1 DSN kết nối SQL-Server đến DB