Advertisement
dodiindika

JDBC

Jan 23rd, 2018
81
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 4.57 KB | None | 0 0
  1. package latihanjdbc;
  2.  
  3. import java.sql.*;
  4. import java.util.Scanner;
  5.  
  6. public class LatihanJDBC {
  7.  
  8.     private static final String url = "jdbc:mysql://127.0.0.1:3306/karyawan";
  9.     private static final String username = "root";
  10.     private static final String password = "";
  11.  
  12.     public static void main(String[] args) {
  13.         try {
  14.             DriverManager.registerDriver(new com.mysql.jdbc.Driver());
  15.             Connection koneksi = DriverManager.getConnection(url, username, password);
  16.             Scanner sc = new Scanner(System.in);
  17.             while(true) {
  18.                 antarmuka(koneksi, sc);
  19.             }
  20.         }
  21.         catch(SQLException exc) {
  22.             System.err.println(exc.toString());
  23.         }
  24.     }
  25.    
  26.     private static void antarmuka(Connection koneksi, Scanner sc) throws SQLException {
  27.         System.out.println("[1] View");
  28.         System.out.println("[2] Insert");
  29.         System.out.println("[3] Update");
  30.         System.out.println("[4] Delete");
  31.         System.out.print("Masukkan pilihan anda: ");
  32.         int pilihan = sc.nextInt();
  33.         sc.nextLine();
  34.         switch(pilihan) {
  35.             case 1 :
  36.                 view(koneksi, sc);
  37.                 break;
  38.                         case 2 :
  39.                                 insert(koneksi, sc);
  40.                                 break;
  41.             case 3 :
  42.                 update(koneksi,sc);
  43.                 break;
  44.                         case 4 :
  45.                 delete(koneksi,sc);
  46.                 break;
  47.         }
  48.     }
  49.        
  50.         private static void view(Connection koneksi, Scanner sc) throws SQLException {
  51.               Statement pernyataan = koneksi.createStatement();
  52.  
  53.               String sql = "SELECT * FROM data_karyawan";
  54.               ResultSet rs = pernyataan.executeQuery(sql);
  55.               while(rs.next()){
  56.                  int nik  = rs.getInt("nik");
  57.                  String nama = rs.getString("nama");
  58.                  String alamat = rs.getString("alamat");                
  59.                  String no_telp = rs.getString("no_telp");
  60.                  
  61.                  System.out.println("Data Karyawan");
  62.                  System.out.println("Nik: " + nik);
  63.                  System.out.println("Nama: " + nama);
  64.                  System.out.println("Alamat: " + alamat);
  65.                  System.out.println("No Telp: " + no_telp + ",");
  66.                  System.out.println("");
  67.               }
  68.               rs.close();
  69.                 }
  70.    
  71.     private static void insert(Connection koneksi, Scanner sc) throws SQLException {
  72.             Statement pernyataan = koneksi.createStatement();
  73.             System.out.print("masukan NIK: ");
  74.                     String NIK = sc.nextLine();
  75.                    
  76.                     System.out.print("masukan Nama: ");
  77.                     String Nama = sc.nextLine();
  78.                    
  79.                     System.out.print("masukan Alamat: ");
  80.                     String Alamat = sc.nextLine();
  81.                    
  82.                     System.out.print("masukan No Telpon: ");
  83.                     String no_telp = sc.nextLine();
  84.                     pernyataan.executeUpdate("INSERT INTO data_karyawan VALUES ('"+NIK+"', '"+Nama+"', '"+Alamat+"', "+no_telp+")");
  85.                     System.out.println("Insert Sukses");
  86.                     pernyataan.close();
  87.         }
  88.    
  89.     private static void delete(Connection koneksi, Scanner sc) throws SQLException {
  90.                     Statement pernyataan = koneksi.createStatement();
  91.                    
  92.                     System.out.print("masukan NIK Yang Akan Di Hapus: ");
  93.                     String NIK = sc.nextLine();
  94.                    
  95.                     pernyataan.executeUpdate("DELETE FROM data_karyawan WHERE nik='"+NIK+"'");
  96.                     System.out.println("Delete Sukses");
  97.                     pernyataan.close();
  98.     }
  99.    
  100.     private static void update(Connection koneksi, Scanner sc) throws SQLException {
  101.                    Statement peryataan = koneksi.createStatement();
  102.                    
  103.                     System.out.print("masukan NIK Yang Akan Di Update: ");
  104.                     String NIK = sc.nextLine();
  105.                    
  106.                     System.out.print("masukan Nama: ");
  107.                     String Nama = sc.nextLine();
  108.                    
  109.                     System.out.print("masukan Alamat: ");
  110.                     String alamat = sc.nextLine();
  111.                    
  112.                     System.out.print("masukan No Telpon: ");
  113.                     String no_telp = sc.nextLine();
  114.                     peryataan.executeUpdate("UPDATE data_karyawan SET Nama='"+Nama+"',"
  115.                             + " alamat='"+alamat+"', no_telp='"+no_telp+"' WHERE nik='"+NIK+"'");
  116.                     System.out.println("Update Sukses");
  117.                     peryataan.close();
  118.     }
  119.  
  120. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement