Advertisement
Guest User

wojtek sql

a guest
Apr 14th, 2016
70
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 17.86 KB | None | 0 0
  1. /*
  2.  * To change this license header, choose License Headers in Project Properties.
  3.  * To change this template file, choose Tools | Templates
  4.  * and open the template in the editor.
  5.  */
  6.  
  7. /**
  8.  *
  9.  * @author Wojtek
  10.  */
  11.  
  12.  
  13. import java.sql.Connection;
  14. import java.sql.DriverManager;
  15. import java.sql.PreparedStatement;
  16. import java.sql.ResultSet;
  17. import java.sql.SQLException;
  18. import java.sql.Statement;
  19.  
  20. /*
  21.  * To change this license header, choose License Headers in Project Properties.
  22.  * To change this template file, choose Tools | Templates
  23.  * and open the template in the editor.
  24.  */
  25. /**
  26.  *
  27.  * @author 15
  28.  */
  29. public class PostgreSQLDatabase {
  30.  
  31.     public static void connect() {
  32.  
  33.         System.out.println("-------- PostgreSQL "
  34.                 + "JDBC Connection Testing ------------");
  35.  
  36.         try {
  37.  
  38.             Class.forName("org.postgresql.Driver");
  39.  
  40.         } catch (ClassNotFoundException e) {
  41.  
  42.             System.out.println("Where is your PostgreSQL JDBC Driver? "
  43.                     + "Include in your library path!");
  44.             e.printStackTrace();
  45.             return;
  46.  
  47.         }
  48.  
  49.         System.out.println("PostgreSQL JDBC Driver Registered!");
  50.  
  51.         Connection connection = null;
  52.  
  53.         try {
  54.  
  55.             connection = DriverManager.getConnection(
  56.                     "jdbc:postgresql://localhost:5432/lokale", "postgres",
  57.                     "admin");
  58.  
  59.         } catch (SQLException e) {
  60.  
  61.             System.out.println("Connection Failed! Check output console");
  62.             e.printStackTrace();
  63.             return;
  64.  
  65.         }
  66.  
  67.         if (connection != null) {
  68.             System.out.println("You made it, take control your database now!");
  69.         } else {
  70.             System.out.println("Failed to make connection!");
  71.         }
  72.     }
  73.         public static void ZapisCaloscBaza()
  74.         {
  75.             try {
  76.             DriverManager.registerDriver(new org.postgresql.Driver());
  77.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  78.             PreparedStatement pstmt = conn.prepareStatement("INSERT INTO lokal(ID,imie,nazwisko,wspolnota,email,tel1,tel2,ulica,budynek,klatka,mieszkanie,imie2,nazwisko2,email2,pow,sposob,konto,miesieczne,zadluzenie) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?)");
  79.             List temp=Global.pierwszy;
  80.             while (temp!=null)
  81.             {
  82.             pstmt.setString(1, temp.lokal.IDLOK);
  83.             pstmt.setString(2, temp.lokal.imie);
  84.             pstmt.setString(3, temp.lokal.nazwisko);
  85.             pstmt.setString(4, temp.lokal.wspolnota);
  86.             pstmt.setString(5, temp.lokal.email);
  87.             pstmt.setString(6, temp.lokal.tel1);
  88.             pstmt.setString(7, temp.lokal.tel2);
  89.             pstmt.setString(8, temp.lokal.ulica);
  90.             pstmt.setInt(9, temp.lokal.budynek);
  91.             pstmt.setString(10, temp.lokal.klatka);
  92.             pstmt.setString(11, temp.lokal.mieszkanie);
  93.             pstmt.setString(12, temp.lokal.imie2);
  94.             pstmt.setString(13, temp.lokal.nazwisko2);
  95.             pstmt.setString(14, temp.lokal.email2);
  96.             pstmt.setDouble(15, temp.lokal.pow);
  97.             pstmt.setInt(16, temp.lokal.sposob);
  98.             pstmt.setString(17, temp.lokal.konto);
  99.             pstmt.setDouble(18, temp.lokal.miesieczne);
  100.             pstmt.setDouble(19, temp.lokal.zadluzenie);
  101.             pstmt.executeUpdate();
  102.             temp=temp.next;
  103.             }
  104.             pstmt.close();
  105.             conn.close();
  106.            
  107.             } catch (SQLException e) {
  108.             e.printStackTrace();
  109.            
  110.         }
  111.            
  112.         }
  113.         public static void Dopisz(Lokal temp)
  114.         {
  115.             try {
  116.             DriverManager.registerDriver(new org.postgresql.Driver());
  117.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  118.             PreparedStatement pstmt = conn.prepareStatement("INSERT INTO lokal(ID,imie,nazwisko,wspolnota,email,tel1,tel2,ulica,budynek,klatka,mieszkanie,imie2,nazwisko2,email2,pow,sposob,konto,miesieczne,zadluzenie,lastedit) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?,?)");
  119.             pstmt.setString(1, temp.IDLOK);
  120.             pstmt.setString(2, temp.imie);
  121.             pstmt.setString(3, temp.nazwisko);
  122.             pstmt.setString(4, temp.wspolnota);
  123.             pstmt.setString(5, temp.email);
  124.             pstmt.setString(6, temp.tel1);
  125.             pstmt.setString(7, temp.tel2);
  126.             pstmt.setString(8, temp.ulica);
  127.             pstmt.setInt(9, temp.budynek);
  128.             pstmt.setString(10, temp.klatka);
  129.             pstmt.setString(11, temp.mieszkanie);
  130.             pstmt.setString(12, temp.imie2);
  131.             pstmt.setString(13, temp.nazwisko2);
  132.             pstmt.setString(14, temp.email2);
  133.             pstmt.setDouble(15, temp.pow);
  134.             pstmt.setInt(16, temp.sposob);
  135.             pstmt.setString(17, temp.konto);
  136.             pstmt.setDouble(18, temp.miesieczne);
  137.             pstmt.setDouble(19, temp.zadluzenie);
  138.             pstmt.setString(20, Global.PracownikIni);
  139.             pstmt.executeUpdate();
  140.            
  141.            
  142.             pstmt.close();
  143.             conn.close();
  144.            
  145.             } catch (SQLException e) {
  146.             e.printStackTrace();
  147.            
  148.         }
  149.            
  150.            
  151.         }
  152.         public static int Znajdz(String ids)
  153.         {
  154.            
  155.             try {
  156.             DriverManager.registerDriver(new org.postgresql.Driver());
  157.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  158.             Statement stmt = conn.createStatement();
  159.             ResultSet rs = stmt.executeQuery("SELECT * FROM lokal");
  160.             while(rs.next()) {
  161.                 if (rs.getString("id") == null ? ids != null : !rs.getString("id").equals(ids))
  162.                 System.out.println(ids+" to nie to -"+rs.getString("id")); else
  163.                 {
  164.                     System.out.println(ids+" to to -"+rs.getString("id"));
  165.                     List temp=new List();
  166.                     Lokal temp1=new Lokal();
  167.                     temp.lokal=temp1;
  168.                     Global.znaleziony=temp;
  169.                     Global.znaleziony.lokal.IDLOK=rs.getString("id");
  170.                     Global.znaleziony.lokal.imie=rs.getString("imie");
  171.                     Global.znaleziony.lokal.nazwisko=rs.getString("nazwisko");
  172.                     Global.znaleziony.lokal.wspolnota=rs.getString("wspolnota");
  173.                     Global.znaleziony.lokal.email=rs.getString("email");
  174.                     Global.znaleziony.lokal.tel1=rs.getString("tel1");
  175.                     Global.znaleziony.lokal.tel2=rs.getString("tel2");
  176.                     Global.znaleziony.lokal.ulica=rs.getString("ulica");
  177.                     Global.znaleziony.lokal.budynek=rs.getInt("budynek");
  178.                     Global.znaleziony.lokal.klatka=rs.getString("klatka");
  179.                     Global.znaleziony.lokal.mieszkanie=rs.getString("mieszkanie");
  180.                     Global.znaleziony.lokal.imie2=rs.getString("imie2");
  181.                     Global.znaleziony.lokal.nazwisko2=rs.getString("nazwisko2");
  182.                     Global.znaleziony.lokal.email2=rs.getString("email2");
  183.                     Global.znaleziony.lokal.pow=rs.getDouble("pow");
  184.                     Global.znaleziony.lokal.sposob=rs.getInt("sposob");
  185.                     Global.znaleziony.lokal.konto=rs.getString("konto");
  186.                     Global.znaleziony.lokal.miesieczne=rs.getDouble("miesieczne");
  187.                     Global.znaleziony.lokal.zadluzenie=rs.getDouble("zadluzenie");
  188.                     rs.close();
  189.             stmt.close();
  190.  
  191.             conn.close();
  192.                     return 1;
  193.                    
  194.                            
  195.                 }
  196.             }
  197.             rs.close();
  198.             stmt.close();
  199.  
  200.             conn.close();
  201.            
  202.             } catch (SQLException e) {
  203.             e.printStackTrace();}
  204.         return 0;
  205.         }
  206.        
  207.         public static void DeleteRow(String id)
  208.   {
  209.      try
  210.      {  
  211.         Class.forName("org.postgresql.Driver");
  212.         Connection connection = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  213.  
  214.        PreparedStatement st = connection.prepareStatement("DELETE FROM lokal WHERE id = ?");
  215.        st.setString(1,id);
  216.        st.executeUpdate();
  217.  
  218.      }
  219.      catch(Exception e)
  220.      {
  221.          System.out.println(e);
  222.      }
  223. }
  224.        
  225.    public static void UpdateRow(String id)
  226.   {
  227.      try
  228.      {  
  229.         Class.forName("org.postgresql.Driver");
  230.         Connection connection = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  231.  
  232.        PreparedStatement st = connection.prepareStatement("UPDATE lokal SET imie = ?, nazwisko =?, wspolnota = ?, email = ?, tel1 = ?, tel2 = ?, ulica = ?, klatka = ?, mieszkanie = ?, imie2 = ?, nazwisko2 = ?, email2= ?, konto= ?, budynek = ?, pow = ?, sposob = ?, miesieczne = ?, zadluzenie = ?, lastedit = ? WHERE id = ?");;
  233.        st.setString(1,Global.znaleziony.lokal.imie);
  234.        st.setString(2,Global.znaleziony.lokal.nazwisko);
  235.        st.setString(3,Global.znaleziony.lokal.wspolnota);
  236.        st.setString(4,Global.znaleziony.lokal.email);
  237.        st.setString(5,Global.znaleziony.lokal.tel1);
  238.        st.setString(6,Global.znaleziony.lokal.tel2);
  239.        st.setString(7,Global.znaleziony.lokal.ulica);
  240.        st.setString(8,Global.znaleziony.lokal.klatka);
  241.        st.setString(9,Global.znaleziony.lokal.mieszkanie);
  242.        st.setString(10,Global.znaleziony.lokal.imie2);
  243.        st.setString(11,Global.znaleziony.lokal.nazwisko2);
  244.        st.setString(12,Global.znaleziony.lokal.email2);
  245.        st.setString(13,Global.znaleziony.lokal.konto);
  246.        st.setInt(14,Global.znaleziony.lokal.budynek);
  247.        st.setDouble(15,Global.znaleziony.lokal.pow);
  248.        st.setInt(16,Global.znaleziony.lokal.sposob);
  249.        st.setDouble(17,Global.znaleziony.lokal.miesieczne);
  250.        st.setDouble(18,Global.znaleziony.lokal.zadluzenie);
  251.        st.setString(19, Global.PracownikIni);
  252.        st.setString(20, id);
  253.        st.executeUpdate();
  254.        
  255. connection.close();
  256.      }
  257.      catch(Exception e)
  258.      {
  259.          System.out.println(e);
  260.      }
  261.  
  262.   }
  263.    
  264.     public static int getSize()
  265.         {
  266.             int i=0;
  267.             try {
  268.             DriverManager.registerDriver(new org.postgresql.Driver());
  269.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  270.             Statement stmt = conn.createStatement();
  271.             ResultSet rs = stmt.executeQuery("SELECT * FROM lokal");
  272.            
  273.             while(rs.next()) {
  274.               i++;  
  275.             }
  276.             return i;
  277.                
  278.             } catch (SQLException e) {
  279.             e.printStackTrace();}
  280.         return i;
  281.         }
  282.     public static List get(int i)
  283.         {
  284.             i++;
  285.             List temp=new List();
  286.                     Lokal temp1=new Lokal();
  287.                
  288.                     temp.lokal=temp1;
  289.                    
  290.                    
  291.             try {
  292.             DriverManager.registerDriver(new org.postgresql.Driver());
  293.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  294.             Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
  295.     ResultSet.CONCUR_READ_ONLY);
  296.             ResultSet rs = stmt.executeQuery("SELECT * FROM lokal");
  297.            
  298.            // for (j=1;j<i;j++)
  299.             //{
  300.                
  301.                 rs.absolute(i);
  302.                
  303.             //}
  304.                    
  305.                    
  306.                     temp.lokal.IDLOK=rs.getString("id");
  307.                     temp.lokal.imie=rs.getString("imie");
  308.                     temp.lokal.nazwisko=rs.getString("nazwisko");
  309.                    temp.lokal.wspolnota=rs.getString("wspolnota");
  310.                     temp.lokal.email=rs.getString("email");
  311.                     temp.lokal.tel1=rs.getString("tel1");
  312.                     temp.lokal.tel2=rs.getString("tel2");
  313.                     temp.lokal.ulica=rs.getString("ulica");
  314.                     temp.lokal.budynek=rs.getInt("budynek");
  315.                     temp.lokal.klatka=rs.getString("klatka");
  316.                     temp.lokal.mieszkanie=rs.getString("mieszkanie");
  317.                     temp.lokal.imie2=rs.getString("imie2");
  318.                     temp.lokal.nazwisko2=rs.getString("nazwisko2");
  319.                     temp.lokal.email2=rs.getString("email2");
  320.                     temp.lokal.pow=rs.getDouble("pow");
  321.                    temp.lokal.sposob=rs.getInt("sposob");
  322.                     temp.lokal.konto=rs.getString("konto");
  323.                     temp.lokal.miesieczne=rs.getDouble("miesieczne");
  324.                     temp.lokal.zadluzenie=rs.getDouble("zadluzenie");
  325.                     rs.close();
  326.            
  327.             stmt.close();
  328.  
  329.             conn.close();
  330.            
  331.                     return temp;
  332.                    
  333.                            
  334.                  
  335.            
  336.            
  337.            
  338.  
  339.            
  340.            
  341.             } catch (SQLException e) {
  342.             e.printStackTrace();}
  343.         return temp;
  344.         }
  345.        
  346.    
  347.     public static void pobierzcalosc ()
  348.     {
  349.         try
  350.         {
  351.            DriverManager.registerDriver(new org.postgresql.Driver());
  352.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  353.             Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
  354.             ResultSet.CONCUR_READ_ONLY);
  355.             ResultSet rs = stmt.executeQuery("SELECT * FROM lokal");
  356.              List temp=null;
  357.              Lokal temp1=null;
  358.              
  359.              
  360.            
  361.              
  362.              while (rs.next())
  363.              {
  364.                  if (temp==null)
  365.                  {
  366.                      temp=new List();
  367.                      temp1=new Lokal();
  368.                      temp.lokal=temp1;
  369.                      
  370.                  } else
  371.                  {
  372.                      temp.next=new List();
  373.                      temp.next.lokal=new Lokal();
  374.                      temp=temp.next;
  375.                      
  376.                  }
  377.                   temp.lokal.IDLOK=rs.getString("id");
  378.                     temp.lokal.imie=rs.getString("imie");
  379.                     temp.lokal.nazwisko=rs.getString("nazwisko");
  380.                    temp.lokal.wspolnota=rs.getString("wspolnota");
  381.                     temp.lokal.email=rs.getString("email");
  382.                     temp.lokal.tel1=rs.getString("tel1");
  383.                     temp.lokal.tel2=rs.getString("tel2");
  384.                     temp.lokal.ulica=rs.getString("ulica");
  385.                     temp.lokal.budynek=rs.getInt("budynek");
  386.                     temp.lokal.klatka=rs.getString("klatka");
  387.                     temp.lokal.mieszkanie=rs.getString("mieszkanie");
  388.                     temp.lokal.imie2=rs.getString("imie2");
  389.                     temp.lokal.nazwisko2=rs.getString("nazwisko2");
  390.                     temp.lokal.email2=rs.getString("email2");
  391.                     temp.lokal.pow=rs.getDouble("pow");
  392.                    temp.lokal.sposob=rs.getInt("sposob");
  393.                     temp.lokal.konto=rs.getString("konto");
  394.                     temp.lokal.miesieczne=rs.getDouble("miesieczne");
  395.                     temp.lokal.zadluzenie=rs.getDouble("zadluzenie");
  396.              if (Global.pierwszy==null) Global.pierwszy=temp;
  397.              }
  398.              
  399.                      }
  400.         catch (SQLException e) {
  401.             e.printStackTrace();}
  402.     }
  403.    
  404.     public static void readStawkiBaza ()
  405.     {
  406.        
  407.         try
  408.         {
  409.            DriverManager.registerDriver(new org.postgresql.Driver());
  410.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  411.             Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
  412.             ResultSet.CONCUR_READ_ONLY);
  413.             ResultSet rs = stmt.executeQuery("SELECT * FROM stawki");
  414.             while (rs.next())
  415.             {
  416.                
  417.                 Global.stawkaconst=rs.getDouble("const");
  418.                 Global.stawkam2=rs.getDouble("m2");
  419.             }
  420.         }
  421.          catch (SQLException e) {
  422.             e.printStackTrace();}
  423.     }
  424.     public static void saveStawkiBaza ()
  425.     {
  426.         try {
  427.             DriverManager.registerDriver(new org.postgresql.Driver());
  428.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  429.             PreparedStatement pstmt = conn.prepareStatement("UPDATE stawki SET const = ?, m2= ? WHERE id = 1");
  430.             pstmt.setDouble(1, Global.stawkaconst);
  431.             pstmt.setDouble(2, Global.stawkam2);
  432.             pstmt.executeUpdate();
  433.             pstmt.close();
  434.             conn.close();
  435.         }
  436.         catch (SQLException e) {
  437.             e.printStackTrace();}
  438.        
  439.        
  440.        
  441.     }
  442.    
  443.     public static int werprac(String id, String nazwisko, String imie)
  444.     {
  445.         //int wystapienie=0;
  446.         try {
  447.             DriverManager.registerDriver(new org.postgresql.Driver());
  448.             Connection conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/lokale", "postgres", "admin");
  449.             Statement stmt = conn.createStatement();
  450.             ResultSet rs = stmt.executeQuery("SELECT * FROM pracownik");
  451.             while(rs.next()) {
  452.                 if ((rs.getString("id").equals(id)) && ((!rs.getString("imie").equals(imie)) || (!rs.getString("nazwisko").equals(nazwisko)))) { System.out.println("Już istnieje"); return 1; } else {System.out.println(rs.getString("id")+" to nie to co "+id);}
  453.                
  454.             }
  455.        
  456.         return 0;
  457.     } catch (SQLException e) {
  458.             e.printStackTrace();
  459.     return 0;}
  460.     }
  461.    
  462.         }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement