HarrJ

Day 26 query methods

Jul 21st, 2023
1,381
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 5.96 KB | None | 0 0
  1. package projectSamples;
  2. import java.sql.*;
  3.  
  4. public class Day26Emp {
  5.     public int addNewEmployee(String fName, String lName, String dept
  6.         ,String phone, String sex, double salary, String bday){
  7.         int rowsAffected = 0;
  8.         String address = "jdbc:mysql://localhost:3306/db_mng_b2";
  9.         String userName = "root";
  10.         String passWord = "";
  11.         String sqlQuery = "INSERT INTO tbl_employee " +
  12.                 "(fld_fname ,fld_lname ,fld_work_dept"
  13.                 + ",fld_phone ,fld_sex ,fld_salary ,fld_birthday)" +
  14.                 "VALUES (? ,? ,? ,? ,? ,? ,?)";
  15.    
  16.         try {
  17.             Connection conn = DriverManager.getConnection(
  18.                     address,userName,passWord);
  19.             PreparedStatement stmt = conn.prepareStatement(sqlQuery);
  20.            
  21.             stmt.setString(1, fName);
  22.             stmt.setString(2, lName);
  23.             stmt.setString(3, dept);
  24.             stmt.setString(4, phone);
  25.             stmt.setString(5, sex);
  26.             stmt.setDouble(6, salary);
  27.             stmt.setString(7, bday);
  28.            
  29.             rowsAffected = stmt.executeUpdate();
  30.            
  31.             conn.close();
  32.         } catch (Exception e) {
  33.             System.out.println(e.getMessage());
  34.         }
  35.    
  36.         return rowsAffected;
  37.     }
  38.    
  39.     public void getRows() {
  40.         String address = "jdbc:mysql://localhost:3306/db_mng_b2";
  41.         String userName = "root";
  42.         String passWord = "";
  43.         String sqlQuery = "SELECT fld_enum"
  44.                 + ", fld_fname, fld_lname"
  45.                 + ", fld_work_dept, fld_phone"
  46.                 + ", fld_sex, fld_salary, fld_birthday"
  47.                 + " FROM tbl_employee";
  48.         try {
  49.             Connection conn = DriverManager.getConnection(
  50.                     address,userName,passWord);
  51.             PreparedStatement stmt = conn.prepareStatement(sqlQuery);
  52.            
  53.             ResultSet rs = stmt.executeQuery();
  54.             while (rs.next()) {
  55.                 System.out.println(String.format(
  56.                     "%-3d | %-18s | %-18s | %-3s | %-18s | %1s | %9.4f | %-10s"
  57.                     ,rs.getInt(1)
  58.                     ,rs.getString(2)
  59.                     ,rs.getString(3)
  60.                     ,rs.getString(4)
  61.                     ,rs.getString(5)
  62.                     ,rs.getString(6)
  63.                     ,rs.getDouble(7)
  64.                     ,rs.getString(8)
  65.                 ));
  66.             }
  67.            
  68.             conn.close();
  69.         } catch (Exception e) {
  70.             System.out.println(e.getMessage());
  71.         }
  72.     }
  73.    
  74.     public void getRows(String searchDept) {
  75.         //method override, select where by fld_work_dept
  76.         String address = "jdbc:mysql://localhost:3306/db_mng_b2";
  77.         String userName = "root";
  78.         String passWord = "";
  79.         String sqlQuery = "SELECT fld_enum"
  80.                 + ", fld_fname, fld_lname"
  81.                 + ", fld_work_dept, fld_phone"
  82.                 + ", fld_sex, fld_salary, fld_birthday"
  83.                 + " FROM tbl_employee"
  84.                 + " WHERE fld_work_dept = ?";
  85.         try {
  86.             Connection conn = DriverManager.getConnection(
  87.                     address,userName,passWord);
  88.             PreparedStatement stmt = conn.prepareStatement(sqlQuery);
  89.            
  90.             stmt.setString(1, searchDept);
  91.  
  92.             ResultSet rs = stmt.executeQuery();
  93.             while (rs.next()) {
  94.                 System.out.println(String.format(
  95.                     "%-3d | %-18s | %-18s | %-3s | %-18s | %1s | %9.4f | %-10s"
  96.                     ,rs.getInt(1)
  97.                     ,rs.getString(2)
  98.                     ,rs.getString(3)
  99.                     ,rs.getString(4)
  100.                     ,rs.getString(5)
  101.                     ,rs.getString(6)
  102.                     ,rs.getDouble(7)
  103.                     ,rs.getString(8)
  104.                 ));
  105.             }
  106.            
  107.             conn.close();
  108.         } catch (Exception e) {
  109.             System.out.println(e.getMessage());
  110.         }
  111.     }
  112.    
  113.     public void getRows(String searchParam, String searchField) {
  114.         //method override, select where by fld_work_dept
  115.         String fieldName = "fld_fname";
  116.         switch (searchField) {
  117.             case "1":
  118.                 fieldName = "fld_fname";
  119.                 break;
  120.             case "2":
  121.                 fieldName = "fld_lname";
  122.                 break;
  123.             case "3":
  124.                 fieldName = "fld_work_dept";
  125.                 break;
  126.             case "4":
  127.                 fieldName = "fld_sex";
  128.                 break;
  129.         }
  130.         searchParam = "%" + searchParam + "%";
  131.        
  132.         String address = "jdbc:mysql://localhost:3306/db_mng_b2";
  133.         String userName = "root";
  134.         String passWord = "";
  135.         String sqlQuery = "SELECT fld_enum"
  136.                 + ", fld_fname, fld_lname"
  137.                 + ", fld_work_dept, fld_phone"
  138.                 + ", fld_sex, fld_salary, fld_birthday"
  139.                 + " FROM tbl_employee"
  140.                 + " WHERE " + fieldName +" LIKE ?";
  141.         try {
  142.             Connection conn = DriverManager.getConnection(
  143.                     address,userName,passWord);
  144.             PreparedStatement stmt = conn.prepareStatement(sqlQuery);
  145.            
  146.             stmt.setString(1, searchParam);
  147.  
  148.             ResultSet rs = stmt.executeQuery();
  149.             while (rs.next()) {
  150.                 System.out.println(String.format(
  151.                     "%-3d | %-18s | %-18s | %-3s | %-18s | %1s | %9.4f | %-10s"
  152.                     ,rs.getInt(1)
  153.                     ,rs.getString(2)
  154.                     ,rs.getString(3)
  155.                     ,rs.getString(4)
  156.                     ,rs.getString(5)
  157.                     ,rs.getString(6)
  158.                     ,rs.getDouble(7)
  159.                     ,rs.getString(8)
  160.                 ));
  161.             }
  162.            
  163.             conn.close();
  164.         } catch (Exception e) {
  165.             System.out.println(e.getMessage());
  166.         }
  167.     }
  168. }
Advertisement
Add Comment
Please, Sign In to add comment