# 1. 检查网络连接
$ ping localfgedu.net.cn
$ telnet localfgedu.net.cn 5432

# 2. 检查PostgreSQL服务状态
$ sudo systemctl status postgresql

# 3. 检查连接字符串
conninfo = “fgedu.net.cn=localfgedu.net.cn port=5432 fgedudb=fgedudb fgedu=pgsql password=postgres_password connect_timeout=10”;

# 4. 解决方法
# 增加连接超时时间
conninfo = “fgedu.net.cn=localfgedu.net.cn port=5432 fgedudb=fgedudb fgedu=pgsql password=postgres_password connect_timeout=30”;

# 检查网络状态
$ netstat -tuln | grep 5432

# 检查防火墙设置
$ sudo firewall-cmd –list-ports

# 1. 分析查询执行计划
$ sudo -u pgsql psql -c “EXPLAIN ANALYZE SELECT * FROM fgedu_employees WHERE age > 30”;

# 2. 检查索引
$ sudo -u pgsql psql -c “\d fgedu_employees”;

# 3. 优化查询
// 使用索引
res = PQexec(conn, “CREATE INDEX idx_employees_age ON fgedu_employees(age)”);

// 优化查询语句
res = PQexec(conn, “SELECT id, name, age FROM fgedu_employees WHERE age > 30”);

# 4. 解决方法
# 创建适当的索引
# 优化查询语句
# 增加服务器资源
# 使用连接池

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

# 2. 创建源文件
$ vi src/main.c

#include
#include
#include
#include

// 函数声明
PGconn *connect_db();
void create_table(PGconn *conn);
void insert_employee(PGconn *conn, const char *name, int age, const char *department);
void query_employees(PGconn *conn);
void update_employee(PGconn *conn, int id, const char *name, int age, const char *department);
void delete_employee(PGconn *conn, int id);
void cleanup(PGconn *conn);

int main() {
PGconn *conn;

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

// 创建表
create_table(conn);

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

// 查询员工
printf(“\n员工列表：\n”);
query_employees(conn);

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

// 查询员工
printf(“\n更新后员工列表：\n”);
query_employees(conn);

// 删除员工
delete_employee(conn, 3);

// 查询员工
printf(“\n删除后员工列表：\n”);
query_employees(conn);

// 清理资源
cleanup(conn);

return 0;
}

PGconn *connect_db() {
PGconn *conn;
char *conninfo;

conninfo = “fgedu.net.cn=localfgedu.net.cn port=5432 fgedudb=fgedudb fgedu=pgsql password=postgres_password”;
conn = PQconnectdb(conninfo);

if (PQstatus(conn) != CONNECTION_OK) {
fprintf(stderr, “连接失败: %s\n”, PQerrorMessage(conn));
return NULL;
}

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

void create_table(PGconn *conn) {
PGresult *res;

res = PQexec(conn, “CREATE TABLE fgedu_IF NOT EXISTS fgedu_employees (\n”
“id SERIAL PRIMARY KEY,\n”
“name VARCHAR(100) NOT NULL,\n”
“age INTEGER NOT NULL,\n”
“department VARCHAR(100) NOT NULL\n”
“)”);

if (PQresultStatus(res) != PGRES_COMMAND_OK) {
fprintf(stderr, “创建表失败: %s\n”, PQerrorMessage(conn));
PQclear(res);
return;
}

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

void insert_employee(PGconn *conn, const char *name, int age, const char *department) {
PGresult *res;
char query[512];

sprintf(query, “INSERT INTO fgedu_employees (name, age, department) VALUES (‘%s’, %d, ‘%s’)”,
name, age, department);

res = PQexec(conn, query);

if (PQresultStatus(res) != PGRES_COMMAND_OK) {
fprintf(stderr, “插入失败: %s\n”, PQerrorMessage(conn));
PQclear(res);
return;
}

printf(“插入员工 %s 成功!\n”, name);
PQclear(res);
}

void query_employees(PGconn *conn) {
PGresult *res;
int nFields, nRows, i, j;

res = PQexec(conn, “SELECT id, name, age, department FROM fgedu_employees”);

if (PQresultStatus(res) != PGRES_TUPLES_OK) {
fprintf(stderr, “查询失败: %s\n”, PQerrorMessage(conn));
PQclear(res);
return;
}

nFields = PQnfields(res);
nRows = PQntuples(res);

// 打印列名
for (i = 0; i < nFields; i++) { printf("%s\t", PQfname(res, i)); } printf("\n"); // 打印数据 for (i = 0; i < nRows; i++) { for (j = 0; j < nFields; j++) { printf("%s\t", PQgetvalue(res, i, j)); } printf("\n"); } PQclear(res); } void update_employee(PGconn *conn, int id, const char *name, int age, const char *department) { PGresult *res; char query[512]; sprintf(query, "UPDATE fgedu_employees SET name='%s', age=%d, department='%s' WHERE id=%d", name, age, department, id); res = PQexec(conn, query); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr, "更新失败: %s\n", PQerrorMessage(conn)); PQclear(res); return; } printf("更新员工 ID=%d 成功!\n", id); PQclear(res); } void delete_employee(PGconn *conn, int id) { PGresult *res; char query[256]; sprintf(query, "DELETE FROM fgedu_employees WHERE id=%d", id); res = PQexec(conn, query); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr, "删除失败: %s\n", PQerrorMessage(conn)); PQclear(res); return; } printf("删除员工 ID=%d 成功!\n", id); PQclear(res); } void cleanup(PGconn *conn) { if (conn) { PQfinish(conn); printf("连接已关闭!\n"); } } # 3. 创建Makefile $ vi Makefile CC = gcc CFLAGS = -Wall -Wextra LIBS = -lpq all: employee_management employee_management: src/main.c $(CC) $(CFLAGS) -o employee_management src/main.c $(LIBS) clean: rm -f employee_management # 4. 编译和运行 $ make $ ./employee_management # 运行结果 连接数据库成功! 创建表成功! 插入员工 风哥1号 成功! 插入员工 风哥2号 成功! 插入员工 王五 成功! 员工列表： id name age department 1 风哥1号 25 技术部 2 风哥2号 30 市场部 3 王五 35 财务部 更新员工 ID=1 成功! 更新后员工列表： id name age department 1 风哥1号 26 技术部 2 风哥2号 30 市场部 3 王五 35 财务部 删除员工 ID=3 成功! 删除后员工列表： id name age department 1 风哥1号 26 技术部 2 风哥2号 30 市场部 连接已关闭!