Разработать информационную систему по продаже автомобилей в автосалоне

    this.server = server;

    try {

      Naming.rebind("//127.0.0.1:"+port+"/SalesServer", this);

    } catch (Exception e) {

      if (e instanceof RemoteException) {

        throw (RemoteException) e;

      } else {

        throw new RemoteException(e.getMessage());

      }

    }

  }

}

 

Листинг кода, демонстрирующий добавление автомобиля в базу данных:

 

public void ADD_CAR(String producer_id, String model, String year, String color, String price, String race) throws RemoteException {

    try {

      rs=server.st.executeQuery("SELECT MAX(car_id) FROM Car");

      rs.next();

      int max=rs.getInt(1);

      max++;

      server.st.executeUpdate( "INSERT INTO Car(car_id,producer_id,model,year,color,price,race) VALUES("+max+","+producer_id+",'"+model+"',"+year+",'"+color+"',"+price+","+race+")");

    }   catch (SQLException ex) {

      System.out.println();

    }

    System.out.println("Adding car...");

  }

 

Листинг кода, демонстрирующий добавление в базу продажи автомобиля:

 

public void ADD_SALE(String client_id, String car_id,String sale_date,String comments) throws RemoteException {

    try {

      rs=server.st.executeQuery("SELECT producer_id FROM Car WHERE car_id="+car_id);

      rs.next();

      String producer_id=rs.getInt(1)+"";

      System.out.println("INSERT INTO Sale VALUES("+client_id+","+car_id+","+producer_id+",'"+sale_date+"','"+comments+"')");

      server.st.executeUpdate( "INSERT INTO Sale VALUES("+client_id+","+car_id+","+producer_id+",'"+sale_date+"','"+comments+"')");

    }

    catch (SQLException ex) {

      System.out.println();

    }

    System.out.println("Adding sale...");

  }

Листинг кода, демонстрирующий  просмотр из базы фотографии автомобиля:

 

public ImageIcon GET_PHOTO(String car_id) throws RemoteException {

    ImageIcon ii = null;

    try {

      rs = server.st.executeQuery( "SELECT photo FROM Car WHERE car_id="+car_id+" AND photo IS NOT NULL");

      if(rs.next())

      {

        InputStream is= rs.getBinaryStream(1);

        byte[] b=new byte[100000];

        is.read(b);

        ii = new ImageIcon(b);

      }     rs.close();

    System.out.println("Getting photo...");

    }

    catch (Exception ex) {

      System.out.println();

    }

    return ii;

  }

 

Листинг кода, демонстрирующий реализацию паттерна Visitor:

 

public interface VisitorCars extends Remote {

        public boolean login(String login, String password) throws RemoteException;

}

  public VisitorCarsImpl(DatabaseConnection databaseConnection)

    throws RemoteException {

this.databaseConnection = databaseConnection;

    }

    public boolean login(String login, String password) {

String query = "SELECT * FROM Producers WHERE login = "+ "'" + login + "'"+ " AND " + "password = "

+ "'" + password + "'";

System.out.println(query);

try {

    ResultSet resultSet = databaseConnection.getStatement().executeQuery(query);

    if(resultSet.next()) {

return resultSet.getBoolean("full");

    }

} catch (SQLException ex) {

    Logger.getLogger(VisitorQueryImpl.class.getName()).log(Level.SEVERE, null, ex);

}

return false;

    }

}

 

Листинг кода, демонстрирующий подключение  клиента к RMI:

 

public ClientFrameDavidovichDA() {

    enableEvents(AWTEvent.WINDOW_EVENT_MASK);

    try {

      opt=new OptionsDavidovichDA();

      if(opt.getError())

        JOptionPane.showMessageDialog(this,opt.getMessage(),"Ошибка при чтении настроек",JOptionPane.ERROR_MESSAGE);

      else

        try {

        System.setSecurityManager(new RMISecurityManager());

        String serverName = java.net.InetAddress.getLocalHost().getHostName();

        iface = (ServerRemoteDavidovichDA) Naming.lookup("//"+opt.getServerName()+":"+opt.getServerPort()+"/SalesServer");

      }  catch (ClassCastException ex) {

        JOptionPane.showMessageDialog(this,"Ошибка приведения интерфейса: "+ex.toString(),"Ошибка при соединении с сервером",JOptionPane.ERROR_MESSAGE);

        } catch (IOException ex) {

          JOptionPane.showMessageDialog(this,"Сервер недоступен","Ошибка при соединении с сервером",JOptionPane.ERROR_MESSAGE);

        }

      jbInit();

    }

    catch(Exception e) {

      e.printStackTrace();

    }

 

  }

Приложение Е

(обязательное)