รู้จักกับ 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": "[email protected]"},

    {"firstName": "Jane", "lastName": "Smith", "age": 17, "email": "[email protected]"},

    {"firstName": "Bob", "lastName": "Johnson", "age": 30, "email": "[email protected]"}

]');

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('[email protected]');

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', '[email protected]'); -- จะ error

INSERT INTO users (username, email) VALUES ('john', 'invalid-email'); -- จะ error

INSERT INTO users (username, email) VALUES ('john', '[email protected]'); -- จะสำเร็จ