Skip to content
Snippets Groups Projects
Commit 0a4ebc90 authored by Ulung32's avatar Ulung32
Browse files

chore: add flow for pesanan and update migration

parent 3ce1a1b9
Branches
Tags
No related merge requests found
......@@ -5,7 +5,7 @@ DROP TABLE IF EXISTS detail_pesanan;
CREATE TABLE pesanan (
id INT PRIMARY KEY,
id INT PRIMARY KEY NOT NULL AUTO_INCREMENT,
id_kurir INT DEFAULT 0,
alamat VARCHAR(255),
nama_penerima VARCHAR(255),
......@@ -15,7 +15,7 @@ CREATE TABLE pesanan (
CREATE TABLE detail_pesanan (
id INT PRIMARY KEY,
id INT PRIMARY KEY NOT NULL AUTO_INCREMENT,
id_pesanan INT,
nama_produk VARCHAR(255),
quantity INT,
......
......@@ -8,6 +8,6 @@ public class Main {
Endpoint.publish("http://0.0.0.0:6001/ws/hello", new ws.TestWSImpl());
System.out.println("Service berhasil di publish");
repository repo = new repository();
System.out.println(repo.getConnection());
// System.out.println(repo.getConnection());
}
}
\ No newline at end of file
package db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class database {
private Connection conn;
public database() {
try {
String url = System.getenv("MYSQL_URL");
String username = System.getenv("MYSQL_USERNAME");
String password = System.getenv("MYSQL_PASSWORD");
System.out.println("ini test");
System.out.println(url);
System.out.println(username);
System.out.println(password);
Class.forName("com.mysql.jdbc.Driver");
System.out.println("ini test2") ;
this.conn = DriverManager.getConnection(url, username, password);
System.out.println("Koneksi ke MySQL berhasil!");
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
System.err.println("Gagal terhubung ke MySQL");
}
}
public Connection getConnection(){
return this.conn;
}
}
package models;
public enum Status {
searching_courier,
pickup,
transit,
delivered
}
package models;
public class model {
//isinya buat model dari data
//ntar bikin anak2nya
}
package models;
public class pesananModel {
private int id_kurir;
private String alamat;
private String nama_penerima;
private Status status;
private String keterangan;
public pesananModel(){
this.id_kurir = 0;
this.alamat = "";
this.nama_penerima = "";
this.status = Status.searching_courier;
this.keterangan = "";
}
public pesananModel(int id_kurir, String alamat, String nama_penerima, Status status, String keterangan){
this.id_kurir = id_kurir;
this.alamat = alamat;
this.nama_penerima = nama_penerima;
this.status = status;
this.keterangan = keterangan;
}
}
package repo;
import java.sql.Connection;
import models.pesananModel;
public class pesananRepo extends repository{
private Connection conn;
public pesananRepo(){
super();
this.conn = this.getDatabase().getConnection();
}
// public pesananModel getPesananById(int id){
// }
}
......@@ -3,37 +3,21 @@ import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import db.database;
public class repository {
//ini gunanya buat ngequery di db
//konekin db ntar di constructor ini
//bikin anak2nya ntar
private Connection connection;
protected database db;
public repository() {
// System.out.println(System.getenv("MYSQL_USERNAME"));
try {
String url = System.getenv("MYSQL_URL");
String username = System.getenv("MYSQL_USERNAME");
String password = System.getenv("MYSQL_PASSWORD");
System.out.println("ini test") ;
System.out.println(url);
System.out.println(username);
System.out.println(password);
Class.forName("com.mysql.jdbc.Driver");
System.out.println("ini test2") ;
this.connection = DriverManager.getConnection(url, username, password);
System.out.println("Koneksi ke MySQL berhasil!");
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
System.err.println("Gagal terhubung ke MySQL");
}
this.db = new database();
}
public Connection getConnection(){
return this.connection;
public database getDatabase() {
return this.db;
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment