1. 先安裝一個(gè)PostgreSQL數(shù)據(jù)庫(kù)
[postgres@pghost ~]$psql
psql (15.8)
2.安裝 psycopg2
yum install postgresql-devel python3-devel
yum install -y python3-psycopg2
pip3 install psycopg2
pip3 install psycopg2-binary
3.游戲代碼克隆
git clone https://github.com/nuno-faria/tetris-sql
chmod +x ./tetris-sql/input.py

1.本地運(yùn)行 Python
python3 input.py \
[-h] [-H HOST] [-P PORT] \
[-d DB] [-u USER] [-p PASSWORD]
2.另一個(gè)終端運(yùn)行以下查詢
psql -U postgres -f tetris-sql/game.sql
說(shuō)明：
game.sql 用于實(shí)現(xiàn)游戲邏輯，主要涉及通用表表達(dá)式（CTE）實(shí)現(xiàn)游戲循環(huán)；
input.py 用于捕獲鍵盤輸入。

CREATE TRIGGER encrypt_phone BEFORE INSERT ON users
FOR EACH ROW EXECUTE FUNCTION encrypt_data();

CREATE OR REPLACE FUNCTION clean_old_logs()
RETURNS VOID AS $$
BEGIN
   DELETE FROM logs WHERE created_at < NOW() - INTERVAL '30 days';
END;
$$ LANGUAGE plpgsql;
-- 每天凌晨執(zhí)行
SELECT cron.schedule('0 0 * * *', 'SELECT clean_old_logs()');

CREATE OR REPLACE FUNCTION migrate_legacy_data()
RETURNS VOID AS $$
DECLARE
   batch_size INT := 1000;
   c CURSOR FOR SELECT * FROM legacy_table;
   r RECORD;
BEGIN
   OPEN c;
   LOOP
      FETCH c INTO r;
      EXIT WHEN NOT FOUND;
      INSERT INTO new_table 
      VALUES (r.id, transform_data(r.raw_content));
      IF (count % batch_size = 0) THEN COMMIT; END IF;
   END LOOP;
   CLOSE c;
END;
$$ LANGUAGE plpgsql;

CREATE OR REPLACE PROCEDURE backup_table(
    table_name TEXT, 
    file_path TEXT DEFAULT '/tmp/backup/'
) 
LANGUAGE plpgsql 
AS $$
DECLARE
    full_path TEXT;
    backup_cmd TEXT;
    file_suffix TEXT := to_char(CURRENT_TIMESTAMP, 'YYYYMMDD_HH24MISS');
BEGIN
    -- 驗(yàn)證表是否存在[7](@ref)
    IF NOT EXISTS (
        SELECT 1 FROM information_schema.tables 
        WHERE table_name = $1 
          AND table_schema = 'public'
    ) THEN
        RAISE EXCEPTION 'Table % does not exist', table_name;
    END IF;
    -- 生成帶時(shí)間戳的文件路徑
    full_path := file_path || table_name || '_' || file_suffix || '.csv';
    -- 構(gòu)建COPY命令（自動(dòng)處理列名）[6](@ref)
    backup_cmd := format(
        'COPY (SELECT * FROM %I) TO %L WITH (FORMAT CSV, HEADER, ENCODING ''UTF8'')', 
        table_name, 
        full_path
    );
    -- 執(zhí)行備份命令
    BEGIN
        EXECUTE backup_cmd;
        RAISE NOTICE 'Table % backed up to %', table_name, full_path;
    EXCEPTION 
        WHEN insufficient_privilege THEN
            RAISE EXCEPTION 'Permission denied for path: %', file_path;
        WHEN others THEN
            RAISE EXCEPTION 'Backup failed: %', SQLERRM;
    END;
END;
$$;