 CREATE TABLE film (
  film_id SERIAL NOT NULL PRIMARY KEY,
  title VARCHAR(100),
  description VARCHAR(255),
  release_year VARCHAR(10),
  language VARCHAR(100),
  rental_duration INT,
  rental_rate DECIMAL(4, 2),
  length INT,
  replacement_cost VARCHAR(100), 
  rating VARCHAR(100),
  last_update TIMESTAMP,
  special_features VARCHAR(100),
  fulltext VARCHAR(255)
);

CREATE TABLE store(
  store_id SERIAL PRIMARY KEY,
  nama_toko VARCHAR(100),
  lokasi VARCHAR(100),
  nomor_telepon VARCHAR(100),
  stok_film INT,
  biaya_sewa DECIMAL(10, 2)
);

CREATE TABLE customer (
    customer_id SERIAL PRIMARY KEY,
    store_id SERIAL,
    first_name VARCHAR(50),
    last_name VARCHAR(50),
    email VARCHAR(255),
    address VARCHAR(255),
    active BOOLEAN DEFAULT TRUE,
    create_date TIMESTAMP,
    last_update TIMESTAMP,
    FOREIGN KEY (store_id) REFERENCES store(store_id)
);

CREATE TABLE inventory (
    inventory_id SERIAL NOT NULL PRIMARY KEY,
    film_id SERIAL,
    store_id SERIAL,
    last_update TIMESTAMP,
    FOREIGN KEY (film_id) REFERENCES film(film_id),
    FOREIGN KEY (store_id) REFERENCES store(store_id)  
);

CREATE TABLE staff (
    staff_id SERIAL PRIMARY KEY,
    store_id SERIAL,
    first_name VARCHAR(50),
    last_name VARCHAR(50),
    email VARCHAR(255),
    active BOOLEAN DEFAULT TRUE,
    username VARCHAR(50),
    password VARCHAR(50),
    create_date TIMESTAMP,
    last_update TIMESTAMP,
    FOREIGN KEY (store_id) REFERENCES store(store_id)
);

CREATE TABLE payment (
    payment_id SERIAL NOT NULL PRIMARY KEY,
    customer_id SERIAL,
    staff_id SERIAL,
    rental_id SERIAL,
    amount DECIMAL(10, 2),
    payment_date DATE,
    FOREIGN KEY (customer_id) REFERENCES customer(customer_id),
    FOREIGN KEY (staff_id) REFERENCES staff(staff_id)
);


CREATE TABLE Rental (
    rental_id SERIAL PRIMARY KEY,
    rental_date TIMESTAMP,
    return_date TIMESTAMP,
    last_update TIMESTAMP,
    inventory_id INT,
    customer_id INT,
    staff_id INT,
    FOREIGN KEY (inventory_id) REFERENCES Inventory(inventory_id),
    FOREIGN KEY (customer_id) REFERENCES Customer(customer_id),
    FOREIGN KEY (staff_id) REFERENCES Staff(staff_id)
);
-- Insert ke tabel film
INSERT INTO film (title, description, release_year, language, rental_duration, rental_rate, length, replacement_cost, rating, last_update, special_features, fulltext)
VALUES ('Nenek sibongkok 3', 'Film Horor', '2024', 'indonesia', 5, 4.99, 120, 'Biaya Penggantian', 'PG-13', NOW(), 'Fitur Khusus', 'Teks Lengkap');
-- Insert ke tabel store
INSERT INTO store (nama_toko, lokasi, nomor_telepon, stok_film, biaya_sewa)
VALUES ('Samya Store', 'Cianjur', '081546439423', 50, 2.99);
-- Insert ke tabel inventory
INSERT INTO inventory (film_id, store_id, last_update)
VALUES (1, 1, NOW());

-- Insert ke tabel staff
INSERT INTO staff (store_id, first_name, last_name, email, active, username, password, create_date, last_update)
VALUES (1, 'Desi', 'Anggarista', '[email protected]', TRUE, 'Desiang', '12345', NOW(), NOW());



SELECT *FROM film;
SELECT *FROM staff;
SELECT *FROM inventory;

-- Prosedur untuk penyewaan film
CREATE OR REPLACE PROCEDURE sewa_film(
    IN p_inventory_id INT,
    IN p_customer_id INT,
    IN p_staff_id INT,
    OUT p_rental_id INT
)
LANGUAGE plpgsql
AS $$
DECLARE
    active_rental_count INT;
BEGIN
    -- Cek apakah ada penyewaan aktif untuk inventory yang sama
    SELECT COUNT(*)
    INTO active_rental_count
    FROM Rental
    WHERE inventory_id = p_inventory_id
    AND return_date IS NULL;

    -- Jika ada penyewaan aktif, kembalikan pesan kesalahan
    IF active_rental_count > 0 THEN
        RAISE EXCEPTION 'Film ini masih disewa!';
    ELSE
        -- Tambahkan penyewaan baru
        INSERT INTO Rental (rental_date, inventory_id, customer_id, staff_id)
        VALUES (CURRENT_TIMESTAMP, p_inventory_id, p_customer_id, p_staff_id)
        RETURNING rental_id INTO p_rental_id;
    END IF;
END;
$$;

-- Prosedur untuk pembayaran penyewaan film
CREATE OR REPLACE PROCEDURE pembayaran_sewa(
    IN p_rental_id INT,
    IN p_amount DECIMAL
)
LANGUAGE plpgsql
AS $$
BEGIN
    -- Lakukan pembayaran
    INSERT INTO payment (rental_id, amount, payment_date)
    VALUES (p_rental_id, p_amount, CURRENT_DATE);
END;
$$;

CREATE OR REPLACE FUNCTION create_rental(
    p_customer_id INT,
    p_inventory_id INT,
    p_staff_id INT
) RETURNS VOID AS $$
DECLARE
    active_rental_count INT;
BEGIN
    -- Hitung jumlah penyewaan yang aktif untuk pelanggan tertentu
    SELECT COUNT(*) INTO active_rental_count
    FROM rental
    WHERE customer_id = p_customer_id
    AND return_date IS NULL;

    -- Jika tidak ada penyewaan yang aktif, buat penyewaan baru
    IF active_rental_count = 0 THEN
        INSERT INTO rental (rental_date, inventory_id, customer_id, staff_id, last_update)
        VALUES (NOW(), p_inventory_id, p_customer_id, p_staff_id, NOW());
        RAISE NOTICE 'Penyewaan berhasil dibuat.';
    ELSE
        RAISE EXCEPTION 'Anda memiliki penyewaan yang masih aktif. Tidak dapat membuat penyewaan baru.';
    END IF;
END;
$$ LANGUAGE plpgsql;

CREATE OR REPLACE FUNCTION make_payment(
    rental_id INT,
    payment_amount DECIMAL
) RETURNS VOID AS $$
DECLARE
    rental_total DECIMAL;
BEGIN
    -- Ambil total pembayaran yang seharusnya dari penyewaan
    SELECT SUM(f.rental_rate) INTO rental_total
    FROM rental r
    JOIN inventory i ON r.inventory_id = i.inventory_id
    JOIN film f ON i.film_id = f.film_id
    WHERE r.rental_id = rental_id;

    -- Periksa apakah jumlah pembayaran sesuai dengan total yang seharusnya
    IF payment_amount >= rental_total THEN
        -- Jika sesuai, buat pembayaran
        INSERT INTO payment (rental_id, amount, payment_date)
        VALUES (rental_id, payment_amount, NOW());
        RAISE NOTICE 'Pembayaran berhasil.';
    ELSE
        -- Jika tidak sesuai, lempar pesan kesalahan
        RAISE EXCEPTION 'Jumlah pembayaran kurang dari total yang seharusnya.';
    END IF;
END;
$$ LANGUAGE plpgsql;

CREATE OR REPLACE FUNCTION update_rental_return_date()
RETURNS TRIGGER AS $$
BEGIN
    -- Update return_date pada rental
    UPDATE rental
    SET return_date = NOW(), last_update = NOW()
    WHERE rental_id = NEW.rental_id;

    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER after_payment_completed
AFTER INSERT ON payment
FOR EACH ROW
EXECUTE FUNCTION update_rental_return_date();

--view unutk menampilkan rental yang masih berjalan
CREATE VIEW ongoing_rentals AS
SELECT 
    c.first_name || ' ' || c.last_name AS nama_penyewa,
    s.nama_toko,
    stf.first_name || ' ' || stf.last_name AS staff_pelayan,
    r.rental_date AS tanggal_peminjaman
FROM 
    rental r
JOIN 
    customer c ON r.customer_id = c.customer_id
JOIN 
    staff stf ON r.staff_id = stf.staff_id
JOIN 
    store s ON c.store_id = s.store_id
WHERE 
    r.return_date IS NULL;
 --view unutk menampilkan rental yang sudah selesai
 CREATE VIEW completed_rentals AS
SELECT 
    c.first_name || ' ' || c.last_name AS nama_penyewa,
    p.amount AS harga_dibayarkan,
    s.nama_toko,
    stf_rental.first_name || ' ' || stf_rental.last_name AS staff_pelayan,
    stf_payment.first_name || ' ' || stf_payment.last_name AS staff_pelayan_pembayaran,
    r.rental_date AS tanggal_peminjaman,
    r.return_date AS tanggal_dikembalikan
FROM 
    rental r
JOIN 
    customer c ON r.customer_id = c.customer_id
JOIN 
    staff stf_rental ON r.staff_id = stf_rental.staff_id
JOIN 
    store s ON c.store_id = s.store_id
JOIN 
    payment p ON r.rental_id = p.rental_id
JOIN 
    staff stf_payment ON p.staff_id = stf_payment.staff_id;
--view untuk mneampilkan jumlah film dalam inventory
CREATE VIEW film_inventory_count AS
SELECT 
    film.title,
    COUNT(*) AS jumlah_film
FROM 
    film
JOIN 
    inventory ON film.film_id = inventory.film_id
GROUP BY 
    film.title;

SELECT * FROM ongoing_rentals;
SELECT * FROM completed_rentals;
SELECT * FROM film_inventory_count;



 CALL  sewa_film(
    1,
    1,
    1,
    1
);

CALL pembayaran_sewa(
    1,
    50000
);

created 1 year ago

PostgreSQL online editor

Write, Run & Share PostgreSQL queries online using OneCompiler's PostgreSQL online editor and compiler for free. It's one of the robust, feature-rich online editor and compiler for PostgreSQL. Getting started with the OneCompiler's PostgreSQL editor is really simple and pretty fast. The editor shows sample boilerplate code when you choose database as 'PostgreSQL' and start writing queries to learn and test online without worrying about tedious process of installation.

About PostgreSQL

PostgreSQL is a open source relational database system and is also knows as Postgres.

Key Features:

Postgres is not only free and open-source but also it is highly extensible.
Custom Data types and funtions from various programming languaues can be introduced and the good part is compiling entire database is not required.
ACID(Atomicity, Consistency, Isolation, Durability) compliant.
First DBMS which implemented Multi-version concurrency control (MVCC) feature.
It's the default database server for MacOS.
It supports all major operating systems like Linux, Windows, OpenBSD,FreeBSD etc.

Syntax help

1. CREATE

CREATE command is used to create a table, schema or an index.

Syntax:

         CREATE TABLE table_name (
                column1 datatype,
                column2 datatype,
                ....);

2. ALTER

ALTER command is used to add, modify or delete columns or constraints from the database table.

Syntax

ALTER TABLE Table_name ADD column_name datatype;

3. TRUNCATE:

TRUNCATE command is used to delete the data present in the table but this will not delete the table.

Syntax

TRUNCATE table table_name;

4. DROP

DROP command is used to delete the table along with its data.

Syntax

DROP TABLE table_name;

5. RENAME

RENAME command is used to rename the table name.

Syntax

ALTER TABLE table_name1 RENAME to new_table_name1;

6. INSERT

INSERT Statement is used to insert new records into the database table.

Syntax

INSERT INTO table_name (column1, column2, column3, ...) VALUES (value1, value2, value3, ...);

7. SELECT

Select statement is used to select data from database tables.

Syntax:

SELECT column1, column2, ...
FROM table_name;

8. UPDATE

UPDATE statement is used to modify the existing values of records present in the database table.

Syntax

UPDATE table_name
SET column1 = value1, column2 = value2, ...
WHERE condition;

9. DELETE

DELETE statement is used to delete the existing records present in the database table.

Syntax

DELETE FROM table_name where condition;