Advertisement
koki2000

MySql class in Java

May 4th, 2019
265
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.05 KB | None | 0 0
  1. package sql;
  2.  
  3. import java.sql.*;
  4. import java.util.ArrayList;
  5.  
  6. public class MySql {
  7.  
  8.     private String host;
  9.     private int port;
  10.     private String username;
  11.     private String password;
  12.     private String database;
  13.  
  14.     private Connection con;
  15.     private Statement st;
  16.     private ResultSet rs;
  17.  
  18.     public MySql()
  19.     {
  20.         this.host ="localhost";
  21.         this.port = 3306;
  22.         this.username = "";
  23.         this.password = "";
  24.         this.database = "";
  25.         this.OpenConnection();
  26.     }
  27.  
  28.     public void OpenConnection()
  29.     {
  30.         try {
  31.             con = DriverManager.getConnection("jdbc:mysql://" + this.host + ":" + this.port + "/" + this.database + "?user=" + this.username + "&password=" + this.password + "&serverTimezone=UTC");
  32.             st = con.createStatement();
  33.         } catch(Exception ex) {
  34.             System.out.println("ERROR: "+ex);
  35.         }
  36.     }
  37.  
  38.     public ResultSet query(String query)
  39.     {
  40.         try {
  41.             st = con.prepareStatement(query);
  42.             rs = st.executeQuery(query);
  43.             return rs;
  44.         } catch(Exception e) {
  45.             e.printStackTrace();
  46.         }
  47.         return null;
  48.     }
  49.  
  50.     public ArrayList<String> sqla(String query)
  51.     {
  52.         ResultSet result = query(query);
  53.        
  54.         ArrayList<String> array = new ArrayList<>();
  55.        
  56.         if( !result.beforeFirst() )
  57.         {
  58.             return array;
  59.         }
  60.        
  61.         while(result.next()))
  62.         {
  63.            
  64.         }
  65.     }
  66.    
  67.     public int insert(String table, String cond)
  68.     {
  69.         String query = "INSERT INTO " + table + " " + cond;
  70.  
  71.         try {
  72.             st = con.createStatement();
  73.             return st.executeUpdate(query);
  74.         } catch (SQLException e) {
  75.             e.printStackTrace();
  76.         }
  77.         return 0;
  78.     }
  79.  
  80.     public int update(String table, String cond)
  81.     {
  82.         String query = "UPDATE " + table + "SET " + cond;
  83.         try {
  84.             st = con.createStatement();
  85.             return st.executeUpdate(query);
  86.         } catch (SQLException e) {
  87.             // TODO Auto-generated catch block
  88.             e.printStackTrace();
  89.         }
  90.         return 0;
  91.     }
  92.  
  93.     public int delete(String table, String cond)
  94.     {
  95.         String query = "DELETE FROM " + table + " " + cond;
  96.  
  97.         try {
  98.             st = con.createStatement();
  99.             return st.executeUpdate(query);
  100.         } catch (Exception e) {
  101.             e.printStackTrace();
  102.         }
  103.         return 0;
  104.     }
  105.  
  106. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement