รู้จักกับ plv8: เมื่อ Postres ต้องมาเชื่อมจิตกับ JavaScript

CREATE EXTENSION plv8

--สรา้งฟังก์ชั่น hellow_world ในการคืนข้อความ "Hello, World!"
CREATE FUNCTION hello_world() RETURNS text AS $$
    return "Hello, World!";
$$ LANGUAGE plv8;

--การเรียกใช้ function hello_world--
SELECT hello_world();

CREATE OR REPLACE FUNCTION filter_and_transform_users(users json) RETURNS json AS $$
    const userArray = JSON.parse(users);
    const result = userArray
        .filter(user => user.age > 18)
        .map(user => ({
            fullName: `${user.firstName} ${user.lastName}`,
            isAdult: user.age >= 21,
            emailDomain: user.email.split('@')[1]
        }));
    return JSON.stringify(result);
$$ LANGUAGE plv8;

-- ตัวอย่างการใช้งาน
SELECT filter_and_transform_users('[
    {"firstName": "John", "lastName": "Doe", "age": 25, "email": "john@example.com"},
    {"firstName": "Jane", "lastName": "Smith", "age": 17, "email": "jane@test.com"},
    {"firstName": "Bob", "lastName": "Johnson", "age": 30, "email": "bob@example.com"}
]');

CREATE OR REPLACE FUNCTION create_counter() RETURNS json AS $$
    const state = plv8.initialize_state();
    if (!state.counter) state.counter = 0;

    function increment() {
        state.counter++;
        return state.counter;
    }

    function decrement() {
        state.counter--;
        return state.counter;
    }

    function reset() {
        state.counter = 0;
        return state.counter;
    }

    return JSON.stringify({increment, decrement, reset});
$$ LANGUAGE plv8;

-- ตัวอย่างการใช้งาน
DO $$
    const counter = JSON.parse(plv8.execute('SELECT create_counter()')[0].create_counter);
    plv8.elog(NOTICE, counter.increment()); // 1
    plv8.elog(NOTICE, counter.increment()); // 2
    plv8.elog(NOTICE, counter.decrement()); // 1
    plv8.elog(NOTICE, counter.reset()); // 0
$$ LANGUAGE plv8;

CREATE OR REPLACE FUNCTION validate_email(email text) RETURNS boolean AS $$
    const validator = require('email-validator');
    return validator.validate(email);
$$ LANGUAGE plv8;

-- ตัวอย่างการใช้งาน
SELECT validate_email('user@example.com');
SELECT validate_email('invalid-email');

-- สรา้งตารางเก็บชื่อผู้ใช้งาน 
CREATE TABLE users (
    id SERIAL PRIMARY KEY,
    username TEXT,
    email TEXT,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

--สร้างฟังก์ชั่น validate_user() ในการตรวจสอบชื่อผู้ใช้งาน และ email
CREATE OR REPLACE FUNCTION validate_user() RETURNS trigger AS $$
    if (!NEW.username || NEW.username.length < 3) {
        plv8.elog(ERROR, 'Username must be at least 3 characters long');
    }
    if (!/^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(NEW.email)) {
        plv8.elog(ERROR, 'Invalid email format');
    }
    return NEW;
$$ LANGUAGE plv8;

--สร้าง trigger ในการเรียกใช้ฟังก์ชั่น validate_user() ในการตรวจสอบชื่อผู้ใช้งาน และ email
CREATE TRIGGER user_validation_trigger
BEFORE INSERT OR UPDATE ON users
FOR EACH ROW EXECUTE FUNCTION validate_user();

-- ตัวอย่างการใช้งาน
INSERT INTO users (username, email) VALUES ('jo', 'john@example.com'); -- จะ error
INSERT INTO users (username, email) VALUES ('john', 'invalid-email'); -- จะ error
INSERT INTO users (username, email) VALUES ('john', 'john@example.com'); -- จะสำเร็จ