CREATE(INSERT)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
| package org.jaco.hibernate; import java.util.Scanner; import org.hibernate.Session; import org.hibernate.cfg.Configuration; public class Main { public static void main(String[] args) { // Buat Session untuk Koneksi Database Session s = new Configuration().configure().buildSessionFactory().openSession(); // Buat Objek dari class Users Users user = new Users(); // Pilih jenis operasi CRUD System.out.println( "Pilih Operasi 1CRUD" ); System.out.println( "1. Create" ); System.out.println( "2. Read" ); System.out.println( "3. Update" ); System.out.println( "4. Delete" ); System.out.print( "Pilihan : " ); int pilih = new Scanner(System.in).nextInt(); switch (pilih) { case 1 : // Create(Insert SQL) // set nilai untuk objek user // user.setID(null) nggak perlu dibuat karena, Auto_Increment user.setNama( "Yudi" ); try { // Mulai Koneksi s.beginTransaction(); // Simpan Objek User ke Session s.save(user); // execute Session ke MySQL s.getTransaction().commit(); } catch (Exception e) { e.printStackTrace(); } break ; default : System.out.println( "Pilihan tidak tersedia" ); } } } |
Kemudian, jalankan file Main.class. Jika output seperti berikut berarti, Anda berhasil melakukan Koneksi Database dan Insert Query. Dan coba cek di tabel database apakah eksekusi query berhasil atau tidak.
READ(SELECT)
Untuk Read, tambahkan coding berikut ke dalam file Main.class.
1
2
3
4
5
6
7
8
| case 2 : // Read(Select SQL) s.beginTransaction(); for (Users us :getAllUsers()) { System.out.println(us); } break ; |
Dan method berikut.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
| // Method untuk select all from table public static List<Users> getAllUsers() { List<Users> list = null ; Session session = new Configuration().configure().buildSessionFactory().openSession(); try { session.beginTransaction(); Query query = session.createQuery( "from org.jaco.hibernate.Users" ); list = query.list(); return list; } catch (Exception e) { e.printStackTrace(); return null ; } } |
Jalankan file Main.class dan input 2.
Jika outputnya, seperti diatas maka, coding Anda berhasil.
UPDATE
Untuk update, tambahkan coding berikut ke dalam file Main.class.
1
2
3
4
5
6
7
8
9
10
11
| case 3 : // Update(Update SQL) s.beginTransaction(); // Set Query SQL Query query = s.createQuery( "update org.jaco.hibernate.Users set nama = :nama where id = :id" ); query.setParameter( "nama" , "Setiawan" ); query.setParameter( "id" , 1 ); int exec = query.executeUpdate(); s.getTransaction().commit(); break ; |
Jalankan file Main.class, input 3 dan cek Outputnya. Dan cek juga hasilnya di table database.
Tidak ada komentar:
Posting Komentar