当前位置：首页 > 行业动态 > 正文

c 数据库连接配置

admin
行业动态
2025-01-31
4

### 本文介绍了MySQL数据库连接配置的相关内容，包括连接字符串各参数的含义、作用及示例，如数据库位置、端口、用户名密码等；还阐述了连接池的作用、优势、配置参数（如池大小、空闲连接数、超时时间）及优化策略，如合理设置连接池参数、选择合适实现、及时关闭连接等；同时提及SQL Server数据库远程连接的配置步骤，涵盖身份验证、入站规则和启动服务等方面。

在C语言中，连接数据库并进行配置通常需要使用特定的数据库接口库，以下是一些常见的数据库和相应的C语言接口库：

数据库类型	接口库
MySQL	MySQL Connector/C
PostgreSQL	libpq
SQLite	SQLite3
Oracle	OCI (Oracle Call Interface)
SQL Server	ODBC (Open Database Connectivity) or DB-Library for Windows

MySQL 数据库连接配置

安装 MySQL Connector/C

你需要安装 MySQL Connector/C，在大多数Linux发行版上，你可以使用包管理器进行安装：

sudo apt-get install libmysqlclient-dev

示例代码

以下是一个使用 MySQL Connector/C 连接到 MySQL 数据库的示例代码：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    const char *server = "localhost";
    const char *user = "root";
    const char *password = "your_password"; /* set me first */
    const char *database = "testdb";
    conn = mysql_init(NULL);
    // 连接到数据库
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 执行查询
    if (mysql_query(conn, "SELECT * FROM test_table")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    res = mysql_use_result(conn);
    // 输出结果
    printf("Results:
");
    while ((row = mysql_fetch_row(res)) != NULL) {
        printf("%st%s
", row[0], row[1]);
    }
    // 关闭连接
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}

2. PostgreSQL 数据库连接配置

c 数据库连接配置

安装 libpq

在大多数Linux发行版上，你可以使用包管理器进行安装：

sudo apt-get install libpq-dev

示例代码

以下是一个使用 libpq 连接到 PostgreSQL 数据库的示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>
void finish_connection(PGconn *conn) {
    PQfinish(conn);
}
int main() {
    const char *conninfo = "host=localhost dbname=testdb user=postgres password=your_password";
    PGconn *conn;
    PGresult *res;
    // 连接到数据库
    conn = PQconnectdb(conninfo);
    if (PQstatus(conn) == CONNECTION_BAD) {
        fprintf(stderr, "Connection to database failed: %s
", PQerrorMessage(conn));
        PQfinish(conn);
        exit(1);
    }
    // 执行查询
    res = PQexec(conn, "SELECT * FROM test_table");
    if (PQresultStatus(res) != PGRES_TUPLES_OK) {
        fprintf(stderr, "Query failed: %s
", PQerrorMessage(conn));
        PQclear(res);
        PQfinish(conn);
        exit(1);
    }
    // 输出结果
    printf("Results:
");
    while ((row = PQgetvalue(res, i, 0)) != NULL) {
        printf("%st%s
", PQgetvalue(res, i, 0), PQgetvalue(res, i, 1));
    }
    // 清理资源
    PQclear(res);
    PQfinish(conn);
    return 0;
}

SQLite 数据库连接配置

安装 SQLite3

在大多数Linux发行版上，你可以使用包管理器进行安装：

c 数据库连接配置

sudo apt-get install libsqlite3-dev

示例代码

以下是一个使用 SQLite3 连接到 SQLite 数据库的示例代码：

#include <sqlite3.h>
#include <stdio.h>
#include <stdlib.h>
int callback(void *NotUsed, int argc, charargv, charazColName) {
    int i;
    for (i = 0; i < argc; i++) {
        printf("%s = %s
", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("
");
    return 0;
}
int main() {
    sqlite3 *db;
    char *zErrMsg = 0;
    int rc;
    const char *sql;
    const char* data = "Callback function called";
    // 打开数据库
    rc = sqlite3_open("test.db", &db);
    if (rc) {
        fprintf(stderr, "Can't open database: %s
", sqlite3_errmsg(db));
        return 0;
    } else {
        fprintf(stderr, "Opened database successfully
");
    }
    // 创建表
    sql = "CREATE TABLE IF NOT EXISTS test_table(" 
          "id INTEGER PRIMARY KEY AUTOINCREMENT," 
          "data TEXT NOT NULL);";
    rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "SQL error: %s
", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Table created successfully
");
    }
    // 插入数据
    sql = "INSERT INTO test_table (data) VALUES ('Sample data');";
    rc = sqlite3_exec(db, sql, callback, (void*)data, &zErrMsg);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "SQL error: %s
", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Records created successfully
");
    }
    // 查询数据
    sql = "SELECT * FROM test_table";
    rc = sqlite3_exec(db, sql, callback, (void*)data, &zErrMsg);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "Failed to select data
");
        fprintf(stderr, "SQL error: %s
", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Operation done successfully
");
    }
    // 关闭数据库连接
    sqlite3_close(db);
    return 0;
}