C++中PostgreSQL的触发器编程实践

在C++中，要使用PostgreSQL触发器，你需要使用libpqxx库，这是一个C++版本的PostgreSQL客户端库

1. 首先，确保已经安装了libpqxx库。在Debian或Ubuntu系统上，可以使用以下命令安装：

sudo apt-get install libpqxx-dev

2. 创建一个PostgreSQL表，用于存储日志信息：

CREATE TABLE log_table (
    id SERIAL PRIMARY KEY,
    table_name TEXT NOT NULL,
    action TEXT NOT NULL,
    old_data TEXT,
    new_data TEXT,
    triggered_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);

3. 创建一个触发器函数，当在log_table表上执行INSERT或UPDATE操作时，将日志信息插入到另一个表log_entries中：

CREATE OR REPLACE FUNCTION log_trigger()
RETURNS TRIGGER AS $$
BEGIN
    IF TG_OP = 'INSERT' THEN
        INSERT INTO log_entries (table_name, action, old_data)
        VALUES (TG_TABLE_NAME, TG_OP, OLD);
    ELSIF TG_OP = 'UPDATE' THEN
        INSERT INTO log_entries (table_name, action, old_data, new_data)
        VALUES (TG_TABLE_NAME, TG_OP, OLD, NEW);
    END IF;
    RETURN NULL;
END;
$$ LANGUAGE plpgsql;

4. 在C++中编写代码，使用libpqxx库连接到PostgreSQL数据库并创建触发器：

#include <iostream>
#include <pqxx/pqxx>

int main() {
    try {
        // 连接到PostgreSQL数据库
        pqxx::connection conn("dbname=your_database user=your_user password=your_password host=your_host port=your_port");
        pqxx::work txn(conn);

        // 创建触发器
        std::string create_trigger_sql = R"(
            CREATE TRIGGER log_trigger
            AFTER INSERT OR UPDATE ON log_table
            FOR EACH ROW EXECUTE FUNCTION log_trigger();
        )";
        txn.exec(create_trigger_sql);

        std::cout << "Trigger created successfully." << std::endl;
    } catch (const pqxx::pqxx_exception &e) {
        std::cerr << "Error: " << e.base().what() << std::endl;
        return 1;
    }

    return 0;
}

5. 编译并运行C++程序：

g++ -o log_trigger log_trigger.cpp -lpqxx -lpq
./log_trigger

现在，当你在log_table表上执行INSERT或UPDATE操作时，触发器将自动将日志信息插入到log_entries表中。你可以使用以下SQL查询查看日志条目：

SELECT * FROM log_entries;