RMI & MySQL-Driver

du skal starte den med MySQL driver jar filen i classpath

java -cp .;C:\mysql\jdbc\mysql-jdbc-driver.jar MinRMIServer

ret selv til så den passer til din konfig

Jah, det løste sørme mit problem. Nu starter den fint op. Nu hvor du er her, kan det så være du kan hjælpe med det næste problem der er opstået. Når jeg kører min StudentClient melder den om en UnmarshalException og endvidere en NotSerializableException på den klasse (ManageDB) jeg bruger til at kalde op til min MySQL-server. Kan lige vedlægge koden:

StudentClient
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
import javax.swing.*;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.rmi.*;
import java.util.Scanner;

public class StudentClient extends JFrame{
   
    public StudentClient(String ip){
        super("RMI StudentClient...");
        getRemoteStud(ip);
        setSize(300,300);
        setResizable(false);
        show();
    }
   
    private void getRemoteStud(String ip){
        Scanner keyB = new Scanner(System.in);
        try{
            String serverObjectName = "//" + ip + "/StudentServer";
            StudentServer mystud = (StudentServer)Naming.lookup(serverObjectName);
            String ssn = "ssn";
            while(ssn != "ssn"){
                System.out.print("Type SSN: ");
                ssn = keyB.next();
                String studentInfo = mystud.getStudentInfo(ssn);

                System.out.print(studentInfo);
            }
        }catch(java.rmi.ConnectException ce){
            System.err.println("Connection to server failed. Server may be temporarily unavailable.");
        }catch(Exception e){
            e.printStackTrace();
            System.exit(1);
        }
    }
   
    public static void main(String[] args){
        StudentClient client = null;
        if(args.length == 0)
            client = new StudentClient("localhost");
        else
            client = new StudentClient(args[0]);
       
        client.addWindowListener(
                new WindowAdapter() {
                    public void windowClosing( WindowEvent e )
                    {
                      System.exit( 0 );
                    }
                }
              );
    }
}

Og dertil kommer klassen ManageDB
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
import java.io.Serializable;
import java.sql.*;;

public class ManageDB implements Serializable{
   
    final ConnectDB db;
    static ManageDB manage = null;
   
    public ManageDB()
    {
        db = ConnectDB.getInstance("jdbc:mysql://localhost/tennisschool?", "root", "123456");
        manage = this;
    }
   
    public String getValue(String wantedField, String table, String compareField, String compareValue){
        String valueString = null;
        try{
            ResultSet value = db.select( "SELECT " + wantedField + " FROM " + table + " WHERE " + compareField + " = " + compareValue );
            while (value.next()){
                valueString = value.getString(wantedField);}
        }catch(Exception e){}
        return valueString;
    }
   
    public String getValue2(String wantedField, String table, String compareField1, String compareValue1, String compareField2, String compareValue2){
        String valueString = null;
        try{
            ResultSet value = db.select( "SELECT " + wantedField + " FROM " + table + " WHERE " + compareField1 + "=" + compareValue1 + " AND " + compareField2 + "='" +  compareValue2 + "'");
            while (value.next()){
                valueString = value.getString(wantedField);}
        }catch(Exception e){}
        return valueString;
    }
   
    public ResultSet getTable(String table){
        return db.select( "SELECT * FROM " + table );
    }
   
    public ResultSet getData(String wantedField, String table, String compareField, String compareValue){
        return db.select( "SELECT " + wantedField + " FROM " + table + " WHERE " + compareField + " = " + compareValue );
    }
   
    public void update( String SQL ){
        db.update( SQL );
    }
   
    public int tableCounter(String table){
        int total = 0;
       
        try
        {
            ResultSet row = db.select( "SELECT COUNT(*) FROM " + table);
            row.next();
            total = row.getInt(1);
           
        }
        catch ( SQLException cs ){
            System.out.println(cs);
        }
       
        return total;
    }
   
    public static ManageDB getInstance(){
        if( manage == null )
            return new ManageDB();
        else return manage;
    }
}

Denne klasse benytter sig af ConnectDB-klassen der sender con.createStatement til MySQL-serveren.

StudentClient er lige lavet lidt om - ville egentlig have det vist i en JFrame, men det er jeg kommet fra igen. Den melder dog stadig samme fejl.

/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

import java.rmi.*;
import java.util.Scanner;

public class StudentClient{
   
    public StudentClient(String ip){
        super();
        getRemoteStud(ip);
    }
   
    private void getRemoteStud(String ip){
        Scanner keyB = new Scanner(System.in);
        try{
            String serverObjectName = "//" + ip + "/StudentServer";
            StudentServer mystud = (StudentServer)Naming.lookup(serverObjectName);
            String ssn = "ssn";
            while(ssn != "ssn"){
                System.out.print("Type SSN: ");
                ssn = keyB.next();
                String studentInfo = mystud.getStudentInfo(ssn);

                System.out.print(studentInfo);
               
//                JPanel p = new JPanel();
//                p.setLayout(null);
//                JLabel student = new JLabel(studentInfo);
//                p.add(student);
//                getContentPane().setLayout( new BorderLayout());
//                getContentPane().add(p, BorderLayout.CENTER);
            }
        }catch(java.rmi.ConnectException ce){
            System.err.println("Connection to server failed. Server may be temporarily unavailable.");
        }catch(Exception e){
            e.printStackTrace();
            System.exit(1);
        }
    }
   
    public static void main(String[] args){
        if(args.length == 0)
            new StudentClient("localhost");
        else
            new StudentClient(args[0]);
    }
}

ManageDB indeholder en ConnectDB

hvis ManageDB skal være serializable så skal ConnectDB også være det

bemærk du kan ikke sende en java.sql.Connection fra server til client

(den er ikke serializable)

Selv om jeg gør ConnectDB serializable, melder den samme fejl. Kan ikke se at jeg sender Connection fra server til client, eller er der noget jeg har misforstået?

din ConnectDB indeholder ikke en Connection ?

Ryder lige op i gamle tråde. Læg et svar arne_v, så får du point for din hjælp.

ok