API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jan 24th, 2018
67
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 18.12 KB | None | 0 0
raw download clone embed print report
  1. package javaapplication4;
  2.  
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintWriter;
  7. import java.net.InetAddress;
  8. import java.net.ServerSocket;
  9. import java.net.Socket;
  10. import java.sql.CallableStatement;
  11. import java.sql.Connection;
  12. import java.sql.DriverManager;
  13. import java.sql.ResultSet;
  14. import java.sql.SQLException;
  15. import java.sql.Statement;
  16. import java.sql.Types;
  17. import javax.swing.JTextArea;
  18. import MetodaSzablonowa.KlientStart;
  19. /*
  20. * To change this license header, choose License Headers in Project Properties.
  21. * To change this template file, choose Tools | Templates
  22. * and open the template in the editor.
  23. */
  24. /**
  25. *
  26. * @author Kamil no i Mateusz
  27. */
  28. public class MyServerForm extends javax.swing.JFrame {
  29. //JavaConnectDB db = new JavaConnectDB();
  30. static String IP = "192.168.1.101";
  31. static Socket s;
  32. static ServerSocket ss;
  33. static InputStreamReader isr;
  34. static BufferedReader br;
  35. static String message;
  36. public static String login_baza="system";
  37. public static String haslo_baza="hr";
  38. public static String okres="Okres trwania";
  39. public static String stawka="Wysokosc stawki";
  40. public MyServerForm() {
  41. initComponents();
  42. }
  43.  
  44.  
  45. @SuppressWarnings("unchecked")
  46. // <editor-fold defaultstate="collapsed" desc="Generated Code">
  47. private void initComponents() {
  48.  
  49. jScrollPane1 = new javax.swing.JScrollPane();
  50. jTextArea1 = new javax.swing.JTextArea();
  51. jButton1 = new javax.swing.JButton();
  52. jTextField1 = new javax.swing.JTextField();
  53.  
  54. setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
  55.  
  56. jTextArea1.setColumns(20);
  57. jTextArea1.setRows(5);
  58. jScrollPane1.setViewportView(jTextArea1);
  59.  
  60. jButton1.setText("jButton1");
  61. jButton1.addMouseListener(new java.awt.event.MouseAdapter() {
  62. public void mouseClicked(java.awt.event.MouseEvent evt) {
  63. jButton1MouseClicked(evt);
  64. }
  65. });
  66.  
  67. jTextField1.setText("jTextField1");
  68.  
  69. javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
  70. getContentPane().setLayout(layout);
  71. layout.setHorizontalGroup(
  72. layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
  73. .addGroup(layout.createSequentialGroup()
  74. .addGap(134, 134, 134)
  75. .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING, false)
  76. .addGroup(layout.createSequentialGroup()
  77. .addComponent(jButton1)
  78. .addGap(45, 45, 45)
  79. .addComponent(jTextField1))
  80. .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, 409, javax.swing.GroupLayout.PREFERRED_SIZE))
  81. .addContainerGap(167, Short.MAX_VALUE))
  82. );
  83. layout.setVerticalGroup(
  84. layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
  85. .addGroup(layout.createSequentialGroup()
  86. .addGap(120, 120, 120)
  87. .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, 305, javax.swing.GroupLayout.PREFERRED_SIZE)
  88. .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
  89. .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.BASELINE)
  90. .addComponent(jButton1)
  91. .addComponent(jTextField1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE))
  92. .addContainerGap(96, Short.MAX_VALUE))
  93. );
  94.  
  95. pack();
  96. }// </editor-fold>
  97.  
  98. private void jButton1MouseClicked(java.awt.event.MouseEvent evt) {
  99. try
  100. {
  101. Socket s=new Socket(IP,7000);
  102. PrintWriter pw = new PrintWriter(s.getOutputStream());
  103. pw.write(jTextField1.getText());
  104. pw.flush();
  105. pw.close();
  106. s.close();
  107. }catch(IOException e)
  108. {
  109. e.printStackTrace();
  110. }
  111.  
  112. }
  113.  
  114. public static void send(String IP, String wiadomosc)
  115. {
  116. try
  117. {
  118. Socket s=new Socket(IP,7000);
  119. PrintWriter pw = new PrintWriter(s.getOutputStream());
  120. pw.write(wiadomosc);
  121. pw.flush();
  122. pw.close();
  123. s.close();
  124. }catch(IOException e)
  125. {
  126. e.printStackTrace();
  127. }
  128. }
  129. /*
  130. public static void interpreter(String tekst)
  131. {
  132. //L|IP|reszta
  133. // L|82626|jahhahs|192.168.1.100
  134.  
  135. String[] parts = message.split("|", 2);
  136. String metoda = parts[0];
  137. String pesel = parts[1];
  138. String tresc = parts[2];
  139. String IP = parts[3];
  140.  
  141. switch(metoda)
  142. {
  143. case "L":
  144. {
  145. System.out.println("L");
  146. //zalogowany(tresc);
  147. break;
  148. }
  149.  
  150. }
  151.  
  152. }
  153. */
  154. public static void wys_k() {
  155. try{
  156. Class.forName("oracle.jdbc.OracleDriver");
  157. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  158.  
  159. Statement st = con.createStatement();
  160. String sql = "select * from dane_osobowe WHERE stanowisko='klient'";
  161. ResultSet rs = st.executeQuery(sql);
  162. while(rs.next()){
  163. send(IP,"K-"+rs.getInt(1)+ "-"+rs.getString(2) + "-"+rs.getString(3)+ "-"+rs.getString(4)+ "-"+rs.getString(7)+ "-"+rs.getString(8));
  164. Thread.sleep(100);
  165. System.out.println(rs.getInt(1)+ "-"+rs.getString(2) + "-"+rs.getString(3)+ "-"+rs.getString(4)+ "-"+rs.getString(7)+ "-"+rs.getString(7));
  166.  
  167. //con.close();
  168. }
  169.  
  170.  
  171.  
  172.  
  173. } catch(Exception e){
  174. System.out.println(e);
  175. }
  176.  
  177. }
  178.  
  179. public static void wys_p() {
  180. try{
  181. Class.forName("oracle.jdbc.OracleDriver");
  182. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  183.  
  184. Statement st = con.createStatement();
  185. String sql = "select * from dane_osobowe WHERE stanowisko='pracownik'";
  186. ResultSet rs = st.executeQuery(sql);
  187. while(rs.next()){
  188. send(IP,"P-"+rs.getInt(1)+ "-"+rs.getString(2) + "-"+rs.getString(3)+ "-"+rs.getString(4)+ "-"+rs.getString(7)+ "-"+rs.getString(8));
  189. Thread.sleep(100);
  190. System.out.println(+rs.getInt(1)+ "-"+rs.getString(2) + "-"+rs.getString(3)+ "-"+rs.getString(4)+ "-"+rs.getString(7)+ "-"+rs.getString(8));
  191.  
  192. //con.close();
  193. }
  194.  
  195.  
  196.  
  197.  
  198. } catch(Exception e){
  199. System.out.println(e);
  200. }
  201.  
  202. }
  203.  
  204. public static void wys_u() {
  205. try{
  206. Class.forName("oracle.jdbc.OracleDriver");
  207. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  208.  
  209. Statement st = con.createStatement();
  210. String sql = "select * from uslugi";
  211. ResultSet rs = st.executeQuery(sql);
  212. while(rs.next()){
  213. send(IP,"U-"+rs.getInt(1)+ "-"+rs.getString(2));
  214. Thread.sleep(100);
  215. System.out.println(rs.getInt(1)+ "-"+rs.getString(2));
  216.  
  217.  
  218. }
  219. con.close();
  220.  
  221.  
  222.  
  223. } catch(Exception e){
  224. System.out.println(e);
  225. }
  226.  
  227. }
  228.  
  229. public static void wys_uk() {
  230. try{
  231. Class.forName("oracle.jdbc.OracleDriver");
  232. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  233.  
  234. Statement st = con.createStatement();
  235. String sql = "SELECT * FROM widok4";
  236. ResultSet rs = st.executeQuery(sql);
  237. while(rs.next()){
  238. send(IP,"S-"+rs.getString(1)+ "-"+rs.getString(2)+ "-"+rs.getInt(3));
  239. Thread.sleep(100);
  240. System.out.println(rs.getString(1)+ "-"+rs.getString(2)+ "-"+rs.getInt(3));
  241.  
  242.  
  243. }
  244. con.close();
  245.  
  246.  
  247.  
  248. } catch(Exception e){
  249. System.out.println(e);
  250. }
  251.  
  252. }
  253.  
  254. public static void licz_em(String tresc) {
  255. String[] parts = tresc.split("-", 4);
  256. IP=parts[0];
  257. try{
  258. Class.forName("oracle.jdbc.OracleDriver");
  259. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  260. // "jdbc:oracle:thin:@localhost:1521:xe","system","oracle");
  261. CallableStatement stmt;
  262. stmt=con.prepareCall ("{? = call spr_ile_do_emerytury(?, ?, ?)}");
  263.  
  264. stmt.registerOutParameter (1, Types.VARCHAR);
  265. System.out.println(parts[2]);
  266. System.out.println(parts[3]);
  267. System.out.println(parts[1]);
  268. stmt.setString(2,parts[2]);
  269. stmt.setString(3,parts[3]);
  270. stmt.setString(4,parts[1]);
  271. stmt.execute();
  272. String output =stmt.getString (1);
  273. System.out.println(output);
  274. send(IP,"E-"+output);
  275. }catch(Exception e){
  276. System.out.println(e);
  277. }
  278.  
  279. }
  280.  
  281. public static void usu_n(String tresc) {
  282. String[] parts = tresc.split("-", 4);
  283. IP=parts[0];
  284. try{
  285. Class.forName("oracle.jdbc.OracleDriver");
  286. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  287. // "jdbc:oracle:thin:@localhost:1521:xe","system","oracle");
  288. CallableStatement stmt;
  289. stmt=con.prepareCall ("{? = call usun_osobe(?, ?, ?)}");
  290.  
  291. stmt.registerOutParameter (1, Types.VARCHAR);
  292. System.out.println(parts[2]);
  293. System.out.println(parts[3]);
  294. System.out.println(parts[1]);
  295. stmt.setString(2,parts[2]);
  296. stmt.setString(3,parts[3]);
  297. stmt.setString(4,parts[1]);
  298. stmt.execute();
  299. String output =stmt.getString (1);
  300. System.out.println(output);
  301. send(IP,"E-"+output);
  302. }catch(Exception e){
  303. System.out.println(e);
  304. }
  305.  
  306. }
  307.  
  308. public static void doda_j(String tresc) {
  309. String[] parts = tresc.split("-", 11);
  310. IP=parts[0];
  311. System.out.println(parts[2]);
  312. System.out.println(parts[3]);
  313. System.out.println(parts[4]);
  314. System.out.println(parts[5]);
  315. System.out.println(parts[1]);
  316. System.out.println(parts[6]);
  317. System.out.println(parts[7]);
  318. System.out.println(parts[8]);
  319. try{
  320. Class.forName("oracle.jdbc.OracleDriver");
  321. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  322. // "jdbc:oracle:thin:@localhost:1521:xe","system","oracle");
  323. CallableStatement stmt;
  324. stmt=con.prepareCall ("{? = call dodaj_osobe(?, ?, ?, ?, ?, ?, ?, ?)}");
  325. //e(imie , nazwisko , wiek ,stanowisko , pesel , nr_tel ,adres , haslo_do_konta )
  326. stmt.registerOutParameter (1, Types.VARCHAR);
  327. stmt.setString(2,parts[2]);
  328. stmt.setString(3,parts[3]);
  329. stmt.setInt(4,Integer.parseInt(parts[4]));
  330. stmt.setString(5,parts[5]);
  331. stmt.setString(6,parts[1]);
  332. stmt.setString(7,parts[6]);
  333. stmt.setString(8,parts[7]);
  334. stmt.setString(9,parts[8]);
  335. // dodaj_osobe('Bartosz','Rusiecki',33,'pracownik','12332112332','147411111','asdasdasd','MVK30PVE9DQ') from dual;
  336.  
  337. //stmt.setString(2,parts[2]);
  338. //stmt.setString(3,parts[3]);
  339. //stmt.setString(4,parts[1]);
  340. stmt.execute();
  341. String output =stmt.getString (1);
  342. System.out.println(output);
  343. send(IP,"A-"+output);
  344. }catch(Exception e){
  345. System.out.println(e);
  346. }
  347.  
  348. }
  349.  
  350.  
  351.  
  352. public static String baza(String aa, String bb) throws SQLException {
  353. // TODO code application logic here
  354.  
  355.  
  356. try{
  357. // OracleDataSource.setPortNumber(1521);
  358. // OraclceDataSource.setDriverType("thin");
  359. Class.forName("oracle.jdbc.OracleDriver");
  360. Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe",login_baza,haslo_baza);
  361. // "jdbc:oracle:thin:@localhost:1521:xe","system","oracle");
  362. CallableStatement stmt;
  363. stmt=con.prepareCall ("{? = call sprawdz_pesel(?, ?)}");
  364.  
  365. stmt.registerOutParameter (1, Types.VARCHAR);
  366. stmt.setString(2,aa);
  367. stmt.setString(3,bb);
  368. stmt.execute();
  369. String output =stmt.getString (1);
  370. System.out.println(output);
  371. return output;
  372. //con.close();
  373.  
  374. }catch(Exception e){
  375. System.out.println(e);
  376. }
  377. return "False";
  378. }
  379.  
  380. public static void poprawna(){
  381.  
  382.  
  383.  
  384. }
  385.  
  386.  
  387. public static void szukanie (String args)
  388. {
  389.  
  390. String str = message;
  391. int firstIndex = str.indexOf('L');
  392. String odp;
  393. String[] parts = str.split("-", 2);
  394. String metoda = parts[0];
  395. String tresc = parts[1];
  396.  
  397. switch(metoda)
  398. {
  399. case "L":
  400. System.out.println("znaleziono logowanie ");
  401.  
  402. try{
  403. String[] parts1 = tresc.split("-", 3);
  404. IP=parts1[0];
  405. String pes = parts1[1];
  406. String has = parts1[2];
  407.  
  408. odp = baza(pes,has);
  409.  
  410. int ffirst = odp.indexOf("P");
  411. int ssecond = odp.indexOf("K");
  412. System.out.println("pass "+ffirst+" hass "+ssecond);
  413. if(ffirst==0)
  414. {
  415. send(IP,"L-true-pracownik");
  416. }
  417. if(ssecond==0)
  418. {
  419. send(IP,"L-true-klient");
  420. }
  421. else
  422. {
  423. send(IP,"L-false-0");
  424. }
  425.  
  426. }
  427. catch(SQLException ex)
  428. {
  429. }
  430.  
  431. break;
  432. case "K":
  433. wys_k();
  434. break;
  435. case "P":
  436. wys_p();
  437. break;
  438. case "U":
  439. wys_u();
  440. break;
  441. case "S":
  442. wys_uk();
  443. break;
  444. case "E":
  445. licz_em(tresc);
  446. break;
  447. case "D":
  448. usu_n(tresc);
  449. break;
  450. case "A":
  451. doda_j(tresc);
  452. break;
  453. case "W": //jak wzorzec
  454. KlientStart.Wzorzec(tresc);
  455. break;
  456.  
  457. }
  458.  
  459.  
  460.  
  461.  
  462.  
  463. }
  464.  
  465.  
  466.  
  467.  
  468. public static void main(String args[]) {
  469. /* Set the Nimbus look and feel */
  470. //<editor-fold defaultstate="collapsed" desc=" Look and feel setting code (optional) ">
  471. /* If Nimbus (introduced in Java SE 6) is not available, stay with the default look and feel.
  472. * For details see http://download.oracle.com/javase/tutorial/uiswing/lookandfeel/plaf.html
  473. */
  474. try {
  475. for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) {
  476. if ("Nimbus".equals(info.getName())) {
  477. javax.swing.UIManager.setLookAndFeel(info.getClassName());
  478. break;
  479. }
  480. }
  481. } catch (ClassNotFoundException ex) {
  482. java.util.logging.Logger.getLogger(MyServerForm.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
  483. } catch (InstantiationException ex) {
  484. java.util.logging.Logger.getLogger(MyServerForm.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
  485. } catch (IllegalAccessException ex) {
  486. java.util.logging.Logger.getLogger(MyServerForm.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
  487. } catch (javax.swing.UnsupportedLookAndFeelException ex) {
  488. java.util.logging.Logger.getLogger(MyServerForm.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
  489. }
  490. //</editor-fold>
  491.  
  492. /* Create and display the form */
  493. java.awt.EventQueue.invokeLater(new Runnable() {
  494. public void run() {
  495. new MyServerForm().setVisible(true);
  496. }
  497. });
  498.  
  499. try{
  500. ss = new ServerSocket(6000);
  501. while(true)
  502. {
  503. s = ss.accept();
  504. isr = new InputStreamReader(s.getInputStream());
  505. br = new BufferedReader(isr);
  506. message = br.readLine();
  507. szukanie(message);
  508.  
  509. System.out.println(message);
  510. //interpreter(message);
  511.  
  512.  
  513. if(jTextArea1.getText().toString().equals(""))
  514. {
  515. jTextArea1.setText(message);
  516.  
  517.  
  518. }
  519.  
  520. else {
  521. jTextArea1.setText(jTextArea1.getText()+ "n"+message);
  522. }
  523.  
  524.  
  525.  
  526. }
  527.  
  528.  
  529. }catch(IOException e)
  530. {
  531. e.printStackTrace();
  532. }
  533. }
  534.  
  535.  
  536.  
  537. // Variables declaration - do not modify
  538. private javax.swing.JButton jButton1;
  539. private javax.swing.JScrollPane jScrollPane1;
  540. private static javax.swing.JTextArea jTextArea1;
  541. private javax.swing.JTextField jTextField1;
  542. // End of variables declaration
  543. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!