2. 首页 > PostgreSQL教程 > 正文

PostgreSQL教程FG124-ECPG基础：C语言中嵌入式SQL使用规范

教程整理：风哥教程  |  更新时间：2026-01-22  |  教程分类：PostgreSQL教程  |  文档学习：16

本文档风哥主要介绍PostgreSQL的ECPG（Embedded SQL in C）基础，包括ECPG的概念、安装、配置、使用方法等内容，风哥教程参考PostgreSQL官方文档ECPG – Embedded SQL in C内容，适合开发人员在学习和测试中使用，如果要应用于生产环境则需要自行确认。

Part01-基础概念与理论知识

1.1 ECPG的概念

ECPG是PostgreSQL的嵌入式SQL预处理器，允许在C语言程序中直接使用SQL语句。它将包含嵌入式SQL语句的C代码转换为标准C代码，然后通过标准C编译器编译。更多视频教程www.fgedu.net.cn

from oracle:www.itpux.com

ECPG的作用：

  • 允许在C语言程序中直接使用SQL语句
  • 简化数据库操作的代码编写
  • 提供类型安全的参数传递
  • 支持事务处理和错误处理
  • 与libpq库兼容，提供更高级的接口

1.2 ECPG的特点

ECPG的主要特点：

  • 嵌入式SQL：在C代码中直接编写SQL语句
  • 类型安全：自动处理C类型和SQL类型之间的转换
  • 预处理：使用ecpg预处理器将嵌入式SQL转换为标准C代码
  • 兼容性：与libpq库兼容，可以混合使用
  • 跨平台：支持多种操作系统和编译器
  • 功能丰富：支持大多数PostgreSQL特性

1.3 ECPG的架构

ECPG的架构：

  • 预处理器：ecpg命令，将嵌入式SQL代码转换为标准C代码
  • 运行时库：libecpg库，提供运行时支持
  • 头文件：ecpglib.h等，提供函数声明和类型定义
  • 编译流程：ecpg预处理 → C编译 → 链接libecpg库
风哥提示：ECPG是PostgreSQL提供的嵌入式SQL解决方案，相比直接使用libpq库，它提供了更高级、更方便的接口，适合开发复杂的数据库应用程序。

Part02-生产环境规划与建议

2.1 ECPG的安装

ECPG的安装方法：

# 在Linux系统上安装ECPG

# 基于RPM的系统（如Oracle Linux、RHEL、CentOS）
$ sudo dnf install postgresql-devel postgresql-server-devel

# 基于DEB的系统（如Ubuntu、Debian）
$ sudo apt-get install postgresql-server-dev-all

# 在macOS上安装ECPG
$ brew install postgresql

# 在Windows上安装ECPG
# 从PostgreSQL官网下载Windows安装包，选择安装”Development Tools”

# 验证ECPG是否安装成功
$ ecpg –version
ecpg (PostgreSQL) 15.0

# 查看ECPG头文件
$ find /usr/include -name “ecpglib.h”
/usr/include/postgresql/ecpglib.h

2.2 ECPG的配置

ECPG的配置选项：

# ECPG预处理器选项

# 基本选项
– -c：生成C代码
– -o file：指定输出文件
– -I directory：指定头文件搜索路径
– -D name=value：定义宏
– -U name：取消定义宏

# 高级选项
– -r：生成可重入代码
– -t：生成调试信息
– -v： verbose模式
– -C：指定C标准（如 -C ANSI, -C ISO, -C GNU）

# 示例
$ ecpg -o example.c example.pgc
$ ecpg -I /usr/include/postgresql example.pgc

2.3 ECPG的使用最佳实践

ECPG的使用最佳实践：

  • 代码组织：将SQL语句与C代码分离，提高可读性
  • 错误处理：妥善处理SQL执行过程中的错误
  • 资源管理：及时释放数据库连接和资源
  • 参数化查询：使用参数化查询，避免SQL注入
  • 事务管理：合理使用事务，确保数据一致性
  • 性能优化：优化SQL语句，减少网络往返
  • 代码风格：保持一致的代码风格，提高可维护性
风哥教程针对风哥教程针对风哥教程针对生产环境建议：在生产环境中，建议使用ECPG的参数化查询功能，避免SQL注入漏洞，同时要注意错误处理和资源管理，确保应用程序的稳定性和安全性。学习交流加群风哥微信: itpux-com

Part03-生产环境项目实施方案

3.1 ECPG基础使用

3.1.1 基本示例

// 基本ECPG示例
// 文件：example.pgc
#include
#include

EXEC SQL BEGIN DECLARE SECTION;
char fgedudb[50] = “fgedudb”;
char fgedu[50] = “postgres”;
char password[50] = “postgres_password”;
int id;
char name[100];
int age;
EXEC SQL END DECLARE SECTION;

int main() {
// 连接数据库
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “连接失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
return 1;
}

printf(“连接数据库成功!\n”);

// 创建表
EXEC SQL CREATE TABLE fgedu_IF NOT EXISTS fgedu_employees (
id SERIAL PRIMARY KEY,
name VARCHAR(100) NOT NULL,
age INTEGER NOT NULL
);
if (sqlca.sqlcode != 0) {
fprintf(stderr, “创建表失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL DISCONNECT;
return 1;
}

printf(“创建表成功!\n”);

// 插入数据
EXEC SQL INSERT INTO fgedu_employees (name, age) VALUES (‘风哥1号’, 25);
if (sqlca.sqlcode != 0) {
fprintf(stderr, “插入数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL DISCONNECT;
return 1;
}

printf(“插入数据成功!\n”);

// 查询数据
EXEC SQL SELECT id, name, age INTO :id, :name, :age FROM fgedu_employees WHERE name = ‘风哥1号’;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “查询数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL DISCONNECT;
return 1;
}

printf(“查询结果: id=%d, name=%s, age=%d\n”, id, name, age);

// 断开连接
EXEC SQL DISCONNECT;

return 0;
}

// 编译步骤
$ ecpg example.pgc
$ gcc -o example example.c -lecpg -lpq

// 运行结果
$ ./example
连接数据库成功!
创建表成功!
插入数据成功!
查询结果: id=1, name=风哥1号, age=25

3.1.2 参数化查询

// 参数化查询示例
// 文件：param_query.pgc
#include
#include

EXEC SQL BEGIN DECLARE SECTION;
char fgedudb[50] = “fgedudb”;
char fgedu[50] = “postgres”;
char password[50] = “postgres_password”;
char name[100];
int age;
int id;
EXEC SQL END DECLARE SECTION;

int main() {
// 连接数据库
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “连接失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
return 1;
}

// 插入数据（参数化）
strcpy(name, “风哥2号”);
age = 30;
EXEC SQL INSERT INTO fgedu_employees (name, age) VALUES (:name, :age);
if (sqlca.sqlcode != 0) {
fprintf(stderr, “插入数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL DISCONNECT;
return 1;
}

printf(“插入数据成功! name=%s, age=%d\n”, name, age);

// 查询数据（参数化）
strcpy(name, “风哥2号”);
EXEC SQL SELECT id, age INTO :id, :age FROM fgedu_employees WHERE name = :name;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “查询数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL DISCONNECT;
return 1;
}

printf(“查询结果: id=%d, name=%s, age=%d\n”, id, name, age);

// 断开连接
EXEC SQL DISCONNECT;

return 0;
}

// 编译步骤
$ ecpg param_query.pgc
$ gcc -o param_query param_query.c -lecpg -lpq

// 运行结果
$ ./param_query
插入数据成功! name=风哥2号, age=30
查询结果: id=2, name=风哥2号, age=30

3.2 ECPG高级使用

3.2.1 游标使用

// 游标使用示例
// 文件：cursor_example.pgc
#include
#include

EXEC SQL BEGIN DECLARE SECTION;
char fgedudb[50] = “fgedudb”;
char fgedu[50] = “postgres”;
char password[50] = “postgres_password”;
int id;
char name[100];
int age;
EXEC SQL END DECLARE SECTION;

int main() {
// 连接数据库
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “连接失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
return 1;
}

// 插入测试数据
EXEC SQL INSERT INTO fgedu_employees (name, age) VALUES (‘王五’, 35);
EXEC SQL INSERT INTO fgedu_employees (name, age) VALUES (‘赵六’, 28);

// 声明游标
EXEC SQL DECLARE emp_cursor CURSOR FOR
SELECT id, name, age FROM fgedu_employees;

// 打开游标
EXEC SQL OPEN emp_cursor;

// 读取数据
printf(“员工列表：\n”);
printf(“ID\t姓名\t年龄\n”);

EXEC SQL WHENEVER NOT FOUND DO break;
while (1) {
EXEC SQL FETCH emp_cursor INTO :id, :name, :age;
printf(“%d\t%s\t%d\n”, id, name, age);
}

// 关闭游标
EXEC SQL CLOSE emp_cursor;

// 断开连接
EXEC SQL DISCONNECT;

return 0;
}

// 编译步骤
$ ecpg cursor_example.pgc
$ gcc -o cursor_example cursor_example.c -lecpg -lpq

// 运行结果
$ ./cursor_example
员工列表：
ID 姓名 年龄
1 风哥1号 25
2 风哥2号 30
3 王五 35
4 赵六 28

3.2.2 事务处理

// 事务处理示例
// 文件：transaction_example.pgc
#include
#include

EXEC SQL BEGIN DECLARE SECTION;
char fgedudb[50] = “fgedudb”;
char fgedu[50] = “postgres”;
char password[50] = “postgres_password”;
int id;
char name[100];
int age;
EXEC SQL END DECLARE SECTION;

int main() {
// 连接数据库
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “连接失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
return 1;
}

// 开始事务
EXEC SQL BEGIN TRANSACTION;

// 插入数据
EXEC SQL INSERT INTO fgedu_employees (name, age) VALUES (‘钱七’, 32);
if (sqlca.sqlcode != 0) {
fprintf(stderr, “插入数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL ROLLBACK;
EXEC SQL DISCONNECT;
return 1;
}

// 更新数据
EXEC SQL UPDATE fgedu_employees SET age = 33 WHERE name = ‘钱七’;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “更新数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL ROLLBACK;
EXEC SQL DISCONNECT;
return 1;
}

// 提交事务
EXEC SQL COMMIT;

// 查询结果
EXEC SQL SELECT id, age INTO :id, :age FROM fgedu_employees WHERE name = ‘钱七’;
if (sqlca.sqlcode != 0) {
fprintf(stderr, “查询数据失败: %s\n”, sqlca.sqlerrm.sqlerrmc);
EXEC SQL DISCONNECT;
return 1;
}

printf(“事务执行成功! id=%d, name=钱七, age=%d\n”, id, age);

// 断开连接
EXEC SQL DISCONNECT;

return 0;
}

// 编译步骤
$ ecpg transaction_example.pgc
$ gcc -o transaction_example transaction_example.c -lecpg -lpq

// 运行结果
$ ./transaction_example
事务执行成功! id=5, name=钱七, age=33

3.3 ECPG错误处理

// 错误处理示例
// 文件：error_handling.pgc
#include
#include

EXEC SQL BEGIN DECLARE SECTION;
char fgedudb[50] = “fgedudb”;
char fgedu[50] = “postgres”;
char password[50] = “postgres_password”;
EXEC SQL END DECLARE SECTION;

// 错误处理函数
void handle_error() {
fprintf(stderr, “SQL错误: %s\n”, sqlca.sqlerrm.sqlerrmc);
fprintf(stderr, “SQL代码: %d\n”, sqlca.sqlcode);
}

int main() {
// 连接数据库
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;
if (sqlca.sqlcode != 0) {
handle_error();
return 1;
}

printf(“连接数据库成功!\n”);

// 故意执行错误的SQL语句
EXEC SQL SELECT * FROM non_existent_table;
if (sqlca.sqlcode != 0) {
handle_error();
// 继续执行
}

// 断开连接
EXEC SQL DISCONNECT;

return 0;
}

// 编译步骤
$ ecpg error_handling.pgc
$ gcc -o error_handling error_handling.c -lecpg -lpq

// 运行结果
$ ./error_handling
连接数据库成功!
SQL错误: ERROR: relation “non_existent_table” does not exist
LINE 1: SELECT * FROM non_existent_table
^
SQL代码: -400

风哥提示：错误处理是ECPG使用中的重要环节，必须对所有可能的错误情况进行处理，避免程序崩溃或行为异常。学习交流加群风哥QQ113257174

Part04-生产案例与实战讲解

4.1 ECPG常见问题

在使用ECPG时，可能会遇到以下问题：

4.1.1 编译错误

# 问题现象：编译ECPG代码时出现错误
# 分析步骤：

# 1. 检查ECPG预处理器是否正确安装
$ ecpg –version
ecpg (PostgreSQL) 15.0

# 2. 检查头文件路径
$ find /usr/include -name “ecpglib.h”
/usr/include/postgresql/ecpglib.h

# 3. 检查编译命令
$ gcc -o example example.c -lecpg -lpq -I/usr/include/postgresql

# 4. 解决方法
# 确保安装了postgresql-devel包
# 确保编译命令中包含了正确的头文件路径和库文件
# 确保ECPG预处理器生成的C代码没有语法错误

4.2 ECPG问题解决方案

# 常见ECPG问题及解决方案

# 1. 编译错误
– 症状：ECPG预处理器或C编译器报错
– 解决方案：
# 检查ECPG安装
$ sudo dnf install postgresql-devel

# 检查编译命令
$ ecpg example.pgc
$ gcc -o example example.c -lecpg -lpq -I/usr/include/postgresql

# 2. 运行时错误
– 症状：程序运行时出现错误
– 解决方案：
# 检查数据库连接参数
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;

# 检查SQL语句语法
EXEC SQL SELECT * FROM fgedu_employees;

# 检查错误处理
if (sqlca.sqlcode != 0) {
handle_error();
}

# 3. 类型不匹配
– 症状：ECPG预处理器报类型不匹配错误
– 解决方案：
# 确保C类型和SQL类型匹配
EXEC SQL BEGIN DECLARE SECTION;
char name[100]; // 对应VARCHAR
int age; // 对应INTEGER
EXEC SQL END DECLARE SECTION;

# 4. 内存泄漏
– 症状：程序内存使用持续增长
– 解决方案：
# 确保断开数据库连接
EXEC SQL DISCONNECT;

# 确保释放游标
EXEC SQL CLOSE emp_cursor;

4.3 ECPG实战案例

# 案例：使用ECPG开发一个员工管理系统

# 1. 项目结构
$ mkdir -p employee_ecpg/src
$ cd employee_ecpg

# 2. 创建源文件
$ vi src/employee.pgc

#include
#include
#include

EXEC SQL BEGIN DECLARE SECTION;
char fgedudb[50] = “fgedudb”;
char fgedu[50] = “postgres”;
char password[50] = “postgres_password”;
int id;
char name[100];
int age;
char department[100];
EXEC SQL END DECLARE SECTION;

// 错误处理函数
void handle_error() {
fprintf(stderr, “SQL错误: %s\n”, sqlca.sqlerrm.sqlerrmc);
fprintf(stderr, “SQL代码: %d\n”, sqlca.sqlcode);
}

// 连接数据库
int connect_db() {
EXEC SQL CONNECT TO :fgedudb USER :fgedu USING :password;
if (sqlca.sqlcode != 0) {
handle_error();
return 0;
}
printf(“连接数据库成功!\n”);
return 1;
}

// 创建表
void create_table() {
EXEC SQL CREATE TABLE fgedu_IF NOT EXISTS fgedu_employees (
id SERIAL PRIMARY KEY,
name VARCHAR(100) NOT NULL,
age INTEGER NOT NULL,
department VARCHAR(100) NOT NULL
);
if (sqlca.sqlcode != 0) {
handle_error();
return;
}
printf(“创建表成功!\n”);
}

// 插入员工
void insert_employee(const char *emp_name, int emp_age, const char *emp_dept) {
strcpy(name, emp_name);
age = emp_age;
strcpy(department, emp_dept);

EXEC SQL INSERT INTO fgedu_employees (name, age, department)
VALUES (:name, :age, :department);
if (sqlca.sqlcode != 0) {
handle_error();
return;
}
printf(“插入员工 %s 成功!\n”, name);
}

// 查询员工
void query_employees() {
EXEC SQL DECLARE emp_cursor CURSOR FOR
SELECT id, name, age, department FROM fgedu_employees;

EXEC SQL OPEN emp_cursor;

printf(“\n员工列表：\n”);
printf(“ID\t姓名\t年龄\t部门\n”);

EXEC SQL WHENEVER NOT FOUND DO break;
while (1) {
EXEC SQL FETCH emp_cursor INTO :id, :name, :age, :department;
printf(“%d\t%s\t%d\t%s\n”, id, name, age, department);
}

EXEC SQL CLOSE emp_cursor;
}

// 更新员工
void update_employee(int emp_id, const char *emp_name, int emp_age, const char *emp_dept) {
id = emp_id;
strcpy(name, emp_name);
age = emp_age;
strcpy(department, emp_dept);

EXEC SQL UPDATE fgedu_employees
SET name = :name, age = :age, department = :department
WHERE id = :id;
if (sqlca.sqlcode != 0) {
handle_error();
return;
}
printf(“更新员工 ID=%d 成功!\n”, id);
}

// 删除员工
void delete_employee(int emp_id) {
id = emp_id;

EXEC SQL DELETE FROM fgedu_employees WHERE id = :id;
if (sqlca.sqlcode != 0) {
handle_error();
return;
}
printf(“删除员工 ID=%d 成功!\n”, id);
}

// 断开连接
void disconnect_db() {
EXEC SQL DISCONNECT;
printf(“连接已关闭!\n”);
}

int main() {
// 连接数据库
if (!connect_db()) {
return 1;
}

// 创建表
create_table();

// 插入员工
insert_employee(“风哥1号”, 25, “技术部”);
insert_employee(“风哥2号”, 30, “市场部”);
insert_employee(“王五”, 35, “财务部”);

// 查询员工
query_employees();

// 更新员工
update_employee(1, “风哥1号”, 26, “技术部”);

// 查询员工
query_employees();

// 删除员工
delete_employee(3);

// 查询员工
query_employees();

// 断开连接
disconnect_db();

return 0;
}

# 3. 创建Makefile
$ vi Makefile

CC = gcc
CFLAGS = -Wall -Wextra -I/usr/include/postgresql
LIBS = -lecpg -lpq

all: employee

employee: src/employee.pgc
ecpg src/employee.pgc
$(CC) $(CFLAGS) -o employee src/employee.c $(LIBS)

clean:
rm -f employee src/employee.c

# 4. 编译和运行
$ make
$ ./employee

# 运行结果
连接数据库成功!
创建表成功!
插入员工 风哥1号 成功!
插入员工 风哥2号 成功!
插入员工 王五 成功!

员工列表：
ID 姓名 年龄 部门
1 风哥1号 25 技术部
2 风哥2号 30 市场部
3 王五 35 财务部

更新员工 ID=1 成功!

员工列表：
ID 姓名 年龄 部门
1 风哥1号 26 技术部
2 风哥2号 30 市场部
3 王五 35 财务部

删除员工 ID=3 成功!

员工列表：
ID 姓名 年龄 部门
1 风哥1号 26 技术部
2 风哥2号 30 市场部

连接已关闭!

风哥教程针对风哥教程针对风哥教程针对生产环境建议：在生产环境中，建议使用ECPG的参数化查询功能，避免SQL注入漏洞，同时要注意错误处理和资源管理，确保应用程序的稳定性和安全性。更多学习教程公众号风哥教程itpux_com

Part05-风哥经验总结与分享

5.1 ECPG最佳实践

ECPG最佳实践：

  • 代码组织：将SQL语句与C代码分离，提高可读性
  • 错误处理：检查所有SQL操作的返回值，妥善处理错误
  • 资源管理：及时释放数据库连接和游标
  • 参数化查询：使用参数化查询，避免SQL注入
  • 事务管理：合理使用事务，确保数据一致性
  • 性能优化：优化SQL语句，减少网络往返
  • 代码风格：保持一致的代码风格，提高可维护性
  • 测试：充分测试应用程序，确保功能正确
风哥提示：ECPG是PostgreSQL提供的强大工具，使用它可以简化C语言程序与PostgreSQL数据库的交互，提高开发效率和代码质量。from PostgreSQL:www.itpux.com

5.2 ECPG性能调优

# ECPG性能调优技巧

# 1. 连接管理
– 使用连接池：减少连接建立和关闭的开销
– 适当设置连接超时：避免连接等待时间过长
– 使用连接复用：在多个请求之间复用连接

# 2. 查询优化
– 使用预处理语句：提高查询执行效率
– 批量操作：减少网络往返次数
– 索引使用：确保查询使用适当的索引
– 游标使用：处理大型结果集

# 3. 内存管理
– 合理分配内存：避免内存泄漏
– 及时释放资源：关闭游标和连接
– 使用适当的数据类型：减少内存使用

# 4. 编译优化
– 使用-O2或-O3优化级别：提高代码执行效率
– 启用警告：-Wall -Wextra
– 使用合适的C标准：-std=c99或-std=c11

# 5. 数据库优化
– 调整PostgreSQL参数：shared_buffers, work_mem等
– 合理设计表结构：使用适当的索引
– 定期维护数据库：VACUUM, ANALYZE

5.3 ECPG工具与资源

ECPG相关工具与资源：

  • ecpg：ECPG预处理器
  • libecpg：ECPG运行时库
  • PostgreSQL官方文档：https://www.postgresql.org/docs/current/ecpg.html
  • ECPG编程指南：https://www.postgresql.org/docs/current/ecpg-programming.html
  • PostgreSQL社区：https://www.postgresql.org/community/
  • 示例代码：PostgreSQL源代码中的ecpg示例
持续改进：ECPG的使用是一个不断学习和优化的过程，建议关注PostgreSQL官方文档和社区资源，及时了解新特性和最佳实践。

本文由风哥教程整理发布,仅用于学习测试使用,转载注明出处:http://www.fgedu.net.cn/10327.html

相关推荐

联系我们

在线咨询：点击这里给我发消息

微信号：itpux-com

工作日：9:30-18:30，节假日休息