САБЖ Мой сервер:
Код | class Listener implements Runnable { ResultSet rs; Socket clientAccepted;
public Listener(Socket aSocket) { clientAccepted = aSocket; }
public void run() { String url = "jdbc:sybase:Tds:localhost:2638"; try { String clientMessage; ObjectInputStream sois = new ObjectInputStream(clientAccepted.getInputStream()); ObjectOutputStream soos = new ObjectOutputStream(clientAccepted.getOutputStream()); String clientMessageRecieved = (String) sois.readObject(); while (clientAccepted.isConnected()) { int h = Integer.parseInt(clientMessageRecieved); switch (h) { case 1: { String nazvanie, brand, strana; int id_tovara, god_vipuska; Vector v = new Vector(); System.out.println(clientMessageRecieved); clientMessage = "Hello! You have connected"; soos.writeObject(clientMessage);
try { try{Class.forName( "com.sybase.jdbc2.jdbc.SybDriver" );} catch(Exception e){ System.out.println("!!!Exception: " + e.getMessage()); e.printStackTrace(); } Connection con = DriverManager.getConnection(url, "dba", "sql"); String stmt_source = "select * from Tovari"; Statement stmt = con.createStatement(); rs = stmt.executeQuery(stmt_source);
while (rs.next()) { id_tovara = rs.getInt("ID_Tovara"); v.addElement(id_tovara); nazvanie = rs.getString("Nazvanie"); v.addElement(nazvanie); god_vipuska = rs.getInt("God_Vipuska"); v.addElement(god_vipuska); brand = rs.getString("Brand"); v.addElement(brand); strana = rs.getString("Strana"); v.addElement(strana); } v.trimToSize(); soos.writeObject(v.size()); Iterator vItr = v.iterator(); while (vItr.hasNext()) { soos.writeObject(vItr.next()); } con.close(); } catch (SQLException sqe) { System.out.println(sqe.getMessage()); sqe.printStackTrace(); } } break;
|
Клиент, кот выводит в таблицу
Код | class Connect implements ActionListener { public void actionPerformed(ActionEvent event) { int number, i, num; int id_tovara, god_v; String nazvanie, brandd, strana; i = 0;
try { try { clientSocket = new Socket("127.0.0.1", 2525); coos = new ObjectOutputStream(clientSocket.getOutputStream()); cois = new ObjectInputStream(clientSocket.getInputStream()); } catch (Exception bn) { }
coos.writeObject("1"); System.setOut(new RusPrintStream()); number = (Integer)cois.readObject(); num = number/5; while(i!=num) { id_tovara = (Integer)cois.readObject(); newContentPane.table.setValueAt(id_tovara,i,0); nazvanie = (String)cois.readObject(); newContentPane.table.setValueAt(nazvanie,i,1); god_v = (Integer)cois.readObject(); newContentPane.table.setValueAt(god_v,i,2); brandd = (String)cois.readObject(); newContentPane.table.setValueAt(brandd,i,3); strana = (String)cois.readObject(); newContentPane.table.setValueAt(strana,i,4); i++; } //-------------------------------------------------------------- // Connect.disable(); } catch (Exception e) { JOptionPane.showMessageDialog(a, "??? ??????????? ? ???????", "????????", JOptionPane.INFORMATION_MESSAGE); } } }
|
Все работает (как бы) но в итоге в таблицу ничего не выводиться (( |