函数原型:MYSQL *mysql_init(MYSQL *mysql)
描述:分配或初始化与mysql_real_connect()相适应的MYSQL对象。如果mysql是NULL指针,该函数将分配、初始化、并返回新对象。否则,将初始化对象,并返回对象的地址。如果mysql_init()分配了新的对象,当调用mysql_close()来关闭连接时。将释放该对象。
返回值:初始化的MYSQL*句柄。如果无足够内存以分配新的对象,返回NULL。
错误:在内存不足的情况下,返回NULL。
函数原型:MYSQL *mysql_real_connect(MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *db, unsigned int port, const char *unix_socket, unsigned long client_flag)
描述:mysql_real_connect( )尝试与运行在主机上的MySQL数据库引擎建立连接。在你能够执行需要有效MySQL连接句柄结构的任何其他API函数之前mysql_real_connect()必须成功完成。
参数说明:
(1)第1个参数应是已有MYSQL结构的地址。
(2)“host”的值必须是主机名或IP地址。如果“host”是NULL或字符串"localhost",连接将被视为与本地主机的连接。
(3)“user”参数包含用户的MySQL登录ID。如果“user”是NULL或空字符串"",用户将被视为当前用户。在UNIX环境下,它是当前的登录名。在Windows ODBC下,必须明确指定当前用户名。
(4)“passwd”参数包含用户的密码。
(5)“db”是数据库名称。
(6)如果“port”不是0,其值将用作TCP/IP连接的端口号。
(7)如果unix_socket不是NULL,该字符串描述了应使用的套接字或命名管道。
(8)client_flag的值通常为0。
返回值:如果连接成功,返回MYSQL*连接句柄。如果连接失败,返回NULL。对于成功的连接,返回值与第1个参数的值相同
示例代码:
#include
#include using namespace std;MYSQL *Init() {MYSQL *m; m = mysql_init(NULL); // 创建mysql对象,并且初始化,返回对象的地址if (NULL == m) {cout << mysql_error(m) << endl; // 打印错误信息return NULL;} m = mysql_real_connect(m, "localhost", "root", "root", "mydatabase", 0, NULL, 0); if (NULL == m) {cout << mysql_error(m) << endl;return NULL;} }int main() {MYSQL *mysql; // 创建mysql对象mysql = Init();if (NULL == mysql) {cout << "初始化mysql失败" << endl;}else {cout << "连接成功" << endl;}return 0;
}
在编译的时候出现了下面这种问题:
编译的时候要加上库的名字
现在编译通过了:
运行结果:
int mysql_query(MYSQL *mysql, const char *query)
#include
#include
#include using namespace std;MYSQL *Init() {MYSQL *m; m = mysql_init(NULL); // 创建mysql对象,并且初始化,返回对象的地址if (NULL == m) {cout << mysql_error(m) << endl; // 打印错误信息return NULL;} m = mysql_real_connect(m, "localhost", "root", "root", "mydatabase", 0, NULL, 0); if (NULL == m) {cout << mysql_error(m) << endl;return NULL;} }void InsertDatabase(MYSQL *m) {if (NULL == m) {return;}char sql[128] = {0};int id, age;char name[32] = {0}, birth[32] = {0}, sex[32] = {0}, tel[32] = {0};cout << "请输入编号、姓名、出生日期、年龄、性别、电话" << endl;cin >> id >> name >> birth >> age >> sex >> tel;sprintf(sql, "insert into student (id, name, birth, age, sex, tel) values (%d, '%s', '%s', %d, '%s', '%s');",id, name, birth, age, sex, tel);int ret = mysql_query(m, sql);if (ret != 0) {cout << mysql_error(m) << endl;return;}cout << "插入成功" << endl;
}int main() {MYSQL *mysql; // 创建mysql对象mysql = Init();if (NULL == mysql) {cout << "初始化mysql失败" << endl;}else {cout << "连接成功" << endl;}// 插入数据InsertDatabase(mysql);return 0;
}
运行结果:
可以看到student这数据库有添加上东西了
但是插入带有中文的数据时,出现了下面的问题:
因此要修改字符集:
现在可以了
MYSQL_RES *mysql_store_result(MYSQL *mysql)
unsigned int mysql_num_fields(MYSQL_RES *result)
运行结果:
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)
完整示例代码:
#include
#include
#include
#include using namespace std;MYSQL *Init() {MYSQL *m; m = mysql_init(NULL); // 创建mysql对象,并且初始化,返回对象的地址if (NULL == m) {cout << mysql_error(m) << endl; // 打印错误信息return NULL;} m = mysql_real_connect(m, "localhost", "root", "root", "mydatabase", 0, NULL, 0); if (NULL == m) {cout << mysql_error(m) << endl;return NULL;} }void InsertDatabase(MYSQL *m) {if (NULL == m) {return;} int ret = mysql_query(m, "set names utf8;");if (ret != 0) {cout << mysql_error(m) << endl;return;}char sql[128] = {0};int id, age;char name[32] = {0}, birth[32] = {0}, sex[32] = {0}, tel[32] = {0};cout << "请输入编号、姓名、出生日期、年龄、性别、电话" << endl;cin >> id >> name >> birth >> age >> sex >> tel;sprintf(sql, "insert into student (id, name, birth, age, sex, tel) values (%d, '%s', '%s', %d, '%s', '%s');",id, name, birth, age, sex, tel);ret = mysql_query(m, sql);if (ret != 0) {cout << mysql_error(m) << endl;return;}cout << "插入成功" << endl;
}void FindDataBase(MYSQL *m) {if (NULL == m) {return;}// 因为后面会输出中文信息mysql_query(m, "set names utf8;");int ret = mysql_query(m, "select * from student;");if (ret != 0) {cout << mysql_error(m) << endl;return;}// 获取查询到的结果MYSQL_RES *res = mysql_store_result(m);if (NULL == res) {cout << mysql_error(m) << endl;return;}// 获取字段数int field = mysql_num_fields(res);//cout << field << endl;MYSQL_FIELD *f; // 结构体,保存每一列的数据while (f = mysql_fetch_field(res)) {// 打印字段名// 宽度为20, 左对齐cout << setw(20) << setiosflags(ios::left) << f->name;}cout << endl;// 获取每一条记录MYSQL_ROW r; // 数组while (r = mysql_fetch_row(res)) {for (int i = 0; i < field; i++) {cout << setw(20) << setiosflags(ios::left) << r[i];}cout << endl;}}int main() {MYSQL *mysql; // 创建mysql对象mysql = Init();if (NULL == mysql) {cout << "初始化mysql失败" << endl;}else {cout << "连接成功" << endl;}// 插入数据//InsertDatabase(mysql);// 查询数据FindDataBase(mysql);return 0;
}