C++连接mysql

  1. // 使用 mysql 提供的进行数据库编程，需要保证当前的应用哦个
  2. // 程序版本(x86/x64)，库文件版本和本机的数据库完全一致。需
  3. // 要将安装目录下的整个 inlcude 文件夹和 lib 路径下的 
  4. // libmysql.lib 和 libmysql.dll 拷贝当当前的项目路径下
  6. #include <stdio.h>
  7. #include <windows.h>
  8. #include "include/mysql.h"
  9. #pragma comment(lib, "libmysql.lib")
  11. // 检查数据库的执行是否成功
  12. void check(MYSQL* mysql)
  13. {
  14.     // mysql_errno 返回的是错误码
  15.     if (mysql_errno(mysql) != 0)
  16.     {
  17.         // mysql_error 返回的是错误信息
  18.         printf("连接数据库出错: %s\n",
  19.             mysql_error(mysql));
  20.         system("pause"); exit(0);
  21.     }
  22. }
  24. // 向指定的表中添加数据
  25. void insert(MYSQL* mysql, LPCSTR sql)
  26. {
  27.     // 直接执行添加数据的操作
  28.     mysql_query(mysql, sql);
  30.     // 需要检查数据是否添加成功
  31.     check(mysql);
  32. }
  34. // 查询指定的数据
  35. void select(MYSQL* mysql, LPCSTR sql)
  36. {
  37.     // 直接执行添加数据的操作
  38.     mysql_query(mysql, sql); 
  39.     check(mysql);
  42.     // 获取到查询的结果值
  43.     MYSQL_RES* pRes = NULL;
  44.     pRes = mysql_use_result(mysql);
  45.     check(mysql);
  47.     // 获取到查询结果有多少
  48.     int nColCount = mysql_num_fields(pRes);
  50.     // 输出每一列的列名
  51.     MYSQL_FIELD* pField = nullptr;
  52.     for (int i = 0; i < nColCount; ++i)
  53.     {
  54.         // 从结果中获取到每一列的名称
  55.         pField = mysql_fetch_field(pRes);
  56.         // 某一些情况下不存在列名不存在的就是 null
  57.         if (pField == nullptr)
  58.             continue;
  59.         printf("%s | ", pField->name);
  60.     }
  61.     puts("");
  63.     // 输出每一个查询到的字段
  64.     MYSQL_ROW row = nullptr;
  65.     while (row = mysql_fetch_row(pRes))
  66.     {   // 获取每一行的信息
  67.         for (int i = 0; i < nColCount; ++i)
  68.         {    // 需要提防产生空指针的情况
  69.             if (row[i] != nullptr)
  70.                 printf("[%s] ", row[i]);
  71.             else
  72.                 printf("[null] ");
  73.         }
  74.         printf("\n");
  75.     }
  76. }
  78. int main(int argc, char* argv[])
  79. {
  80.     // 修改控制台的默认字符编码
  81.     system("chcp 65001");
  83.     // 1. 初始化 mysql 数据库
  84.     mysql_library_init(argc, argv, nullptr);
  86.     // 2. 操作 mysql 数据库需要提供一个 MYSQL 对象
  87.     MYSQL mysql = { 0 };
  88.     mysql_init(&mysql);
  90.     // 3. 连接数据库，需要提供明文的数据库信息
  91.     mysql_real_connect(&mysql, "127.0.0.1", "root", 
  92.         "66666666", "my_table", 3306, nullptr, 0);
  93.     check(&mysql);
  95.     // 4. 向数据库中添加信息
  96.     // insert(&mysql, "INSERT INTO my_class(m_name, m_count) VALUE('41', 41);");
  98.     // 5. 从数据库中查询信息
  99.     select(&mysql, "SELECT * FROM my_student;");
  101.     // 6. 清理 mysql 数据库
  102.     mysql_library_end();
  104.     return 0;
  105. }

python连接mysql

  1. import pymysql
  4. class mysql(object):
  6.     # 连接到数据库
  7.     def __init__(self):
  8.         try:
  9.             # 创建连接对象，连接到数据库
  10.             self.connect = pymysql.connect(host="127.0.0.1",
  11.                     user="root", password="66666666", db="my_table")
  12.             # 获取到游标对象，游标对象被用于执行查询操作
  13.             self.cursor = self.connect.cursor()
  14.         except Exception as e:
  15.             # 一旦出现问题，这里会打印错误信息
  16.             print(e)
  18.     # 添加数据到表中
  19.     def insert(self, sql):
  20.         try:
  21.             # 使用 execute 执行 sql 指令
  22.             self.cursor.execute(sql)
  23.             # 任何对 sql 数据库执行修改的操作都需要提交
  24.             self.connect.commit()
  25.         except Exception as e:
  26.             # 如果指令执行出错，理论应该回滚操作
  27.             self.connect.rollback()
  28.             # 输出错误信息
  29.             print(e)
  31.     # 查询数据，返回查询到的数据和数量
  32.     def select(self, sql):
  33.         try:
  34.             # 使用 execute 执行 sql 指令
  35.             self.cursor.execute(sql)
  36.             # 使用 fetchall 获取所有结果
  37.             result = self.cursor.fetchall()
  38.             # 使用 rowcount 获取返回的条目数量
  39.             count = self.cursor.rowcount
  40.             # 查询到的结果是一个由所有的条目组成的元组
  41.             # 元组的每一个元素又是一个元组，这个元组中
  42.             # 保存的是查询到的每一列的信息
  43.             return count, result
  44.         except Exception as e:
  45.             # 如果指令执行出错，理论应该回滚操作
  46.             self.connect.rollback()
  47.             # 输出错误信息
  48.             print(e)
  51. if __name__ == "__main__":
  52.     sql = mysql()
  53.     # sql.insert("INSERT INTO my_class VALUE(43, '43', 43);")
  54.     print(sql.select("SELECT * FROM my_student;"))