Cum de a aduce completați datele din baza de date de masă prin RMI folosind metoda matrice?

Metode abstracte în interfețe la distanță nu poate fi static, astfel încât aveți nevoie pentru a schimba interfața definiție la următorul.

public interface Interface extends java.rmi.Remote {
    public String[] getArray() throws RemoteException;
}

Valorile returnate de la distanță metode trebuie să fie serializabile. Tablouri în java sunt serializabile, cu toate acestea tablouri au o dimensiune fixă și când te întorci rezultatul de o interogare a bazei de date nu stiu dimensiunea. Prin urmare, am sugera că metoda getArray reveni un ArrayList sau mai bine încă, o CachedRowSet.

public interface Interface extends Remote {
    public CachedRowSet getArray() throws RemoteException;
}

Din clasa TheImplementation este RMI server de clasă, este, probabil, mai bine pentru a vă conecta excepții, mai degrabă decât a afișa o JOptionPane și tu ar trebui să întotdeauna jurnal stivei. Rețineți că de la distanță metode trebuie să declare pe care le arunca RemoteException în scopul de a informa RMI client că metoda de la distanță nu a reușit. Prin urmare, în afară de logare excepție, metoda getArray puteți arunca, de asemenea, un RemoteException.

Codul de mai jos demonstrează.

import java.rmi.Remote;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.rowset.CachedRowSet;
import javax.sql.rowset.RowSetFactory;
import javax.sql.rowset.RowSetProvider;

public class TheImplementation extends UnicastRemoteObject implements Interface {

    public TheImplementation() throws RemoteException {
        super();
    }

    private static final long serialVersionUID = -3763231206310559L;

    public CachedRowSet getArray() throws RemoteException {
        try (Connection con = ConnectionProvider.getConnection();
             Statement st = con.createStatement();
             ResultSet rs = st.executeQuery("select * from details")) {
            RowSetFactory factory = RowSetProvider.newFactory();
            CachedRowSet fruitDetails = factory.createCachedRowSet();
            fruitDetails.populate(rs);
            return fruitDetails;
        }
        catch (SQLException e) {
            throw new RemoteException("Method 'getArray()' failed.", e);
        }
    }
}

Rețineți că codul de mai sus utilizează, de asemenea, încercați-cu-resurse pentru a se asigura că ResultSet, Statement și Connection sunt toate închise.