c++与golang操作数据库总结【c++与golang】_c++和go

---

前言

C++和Go语言都可以通过第三方库或内置的库来连接到不同类型的数据库，并且在连接成功后可以使用SQL语句对数据进行操作。
分析两种语言对数据库的操作异同点有助于
学习两种语言的优劣之处：通过比较这两门语言在处理数据库方面的能力和性能，我们可以更好地理解它们各自的优点和缺点，了解它们在不同情况下的适用性。
提高跨平台开发的能力：由于C++和Go语言都是跨平台的编程语言，因此比较它们在数据库操作方面的异同点，可以帮助我们更好地了解如何在不同的操作系统和硬件平台上进行开发，提高跨平台开发的能力。

一、C++和Go语言对数据库进行操作异同点

相同点
1、C++和Go语言都支持使用第三方库来连接各种类型的数据库（如MySQL、PostgreSQL、SQLite等）。
2、在连接到数据库后，两者都可以执行SQL查询以及其他常见的数据库操作，例如插入、更新和删除数据等。
3、无论是C++还是Go语言，都需要正确设置连接参数，如用户名、密码、主机名、端口号等。
不同点
1、C++是一门编译型语言，而Go语言是一门解释性语言，这意味着C++可执行程序通常比Go语言的二进制文件更快速、更高效。
2、在处理字符串和JSON格式数据时，Go语言提供了更强大的内置功能，使得从数据库中读取和写入数据变得更加容易。相比之下，C++需要借助第三方库，如RapidJSON或nlohmann/json等。
3、C++拥有更多的底层控制权，这使得它可以更好地管理内存和资源，但也可能会导致代码复杂度更高。Go语言则更注重简洁、易读和易于维护，适合构建大型的分布式系统。
4、在异步IO和并发处理方面，Go语言拥有更强大的工具，如goroutines和channels，使得处理高并发任务变得更加容易。C++也有自己的异步IO库，如Boost.Asio等，但相比之下，Go语言在这方面做得更好。

二、c++操作数据库

1、所用到的库

#include <mysql/mysql.h>

1
2

---

2、数据库连接

定义成员变量

static string server = "127.0.0.1";
static string user = "root";
static string password = "123456";
static string dbname = "chat";
1
2
3
4

这里定义了连接数据库所需的四个参数：服务器地址、用户名、密码和数据库名称。
连接数据库

MySQL::MySQL() {
   _conn = mysql_init(nullptr);
}
bool MySQL::connect() {
   MYSQL* p =
       mysql_real_connect(_conn, server.c_str(), user.c_str(), password.c_str(),
                          dbname.c_str(), 3306, nullptr, 0);
   if (p != nullptr) {
      // w为了适配中文
      mysql_query(_conn, "set names gbk");
      LOG_INFO << "connet mysql success!!!";
   } else {
      LOG_INFO << "connet mysql fail!!!";
   }
   return p;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

在构造函数中，使用mysql_init()初始化了一个MYSQL对象，并将其赋值给_conn成员变量。在析构函数中，调用了mysql_close()来关闭MYSQL对象并释放相应的资源。
connect()函数用于连接数据库。这里使用了mysql_real_connect()函数来建立连接。如果连接成功，则将字符集设置为GBK，并输出日志信息。如果连接失败，则输出相应的错误信息。

3、数据库操作类

// 更新操作
bool MySQL::update(string sql) {
   if (mysql_query(_conn, sql.c_str())) {
      LOG_INFO << __FILE__ << ":" << __LINE__ << ":" << sql << "更新失败!";
      return false;
   }
   return true;
}
// 查询操作
MYSQL_RES* MySQL::query(string sql) {
   if (mysql_query(_conn, sql.c_str())) {
      // muduo 库的日志输出
      LOG_INFO << __FILE__ << ":" << __LINE__ << ":" << sql << "查询失败!";
      return nullptr;
   }
   return mysql_use_result(_conn);
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

update()函数用于执行更新（修改、插入或删除）操作。它接受一个SQL语句作为参数，并使用mysql_query()函数来执行该语句。如果执行失败，则输出相应的错误信息并返回false；否则返回true。
query()函数用于执行查询操作。它接受一个SQL语句作为参数，并使用mysql_query()函数来执行该语句。如果执行失败，则输出相应的错误信息并返回nullptr；否则返回一个结果集对象MYSQL_RES*。

4、实际操作

insert()函数用于向数据库中插入一条记录。它接受一个User对象作为参数，并将其属性值组装成SQL语句，使用mysql.update()函数来执行插入操作。如果插入成功，则返回true，并将新插入记录的主键ID设置到User对象的id属性上。

// user 表的增加方法
bool UserModel::insert(User& user) {
   // 组装sql语句
   char sql[1024] = {0};
   sprintf(
       sql, "insert into user(name, password, state) values('%s', '%s', '%s')",
       user.getName().c_str(), user.getPwd().c_str(), user.getState().c_str());
   cout << "insert user" << endl;
   // 插入
   if (mysql.update(sql)) {
      // 返回 主键 id 给user
      user.setId(mysql_insert_id(mysql.getConnection()));
      return true;
   }
   return false;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

query()函数用于从数据库中查询一条记录。它接受一个整型参数作为主键ID，并将其组装成SQL语句，使用mysql.query()函数来执行查询操作。如果查询成功，则将结果集中的数据取出来，并将其封装成一个User对象返回。

User UserModel::query(int id) {
   char sql[1024] = {0};
   sprintf(sql, "select * from user where id = %d ", id);

   auto res = mysql.query(sql);
   if (res != nullptr) {
      // 查询一行  typedef char **MYSQL_ROW;是二维数组类型的
      // 拿出来全部是字符串   并且对应表里面的字段
      MYSQL_ROW row = mysql_fetch_row(res);
      if (row != nullptr) {
         User user;
         user.setId(atoi(row[0]));
         user.setName(row[1]);
         user.setPwd(row[2]);
         user.setState(row[3]);
         // 返回的res是指针  需要释放资源
         mysql_free_result(res);
         return user;
      }
   }
   return User();
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

updateState()函数用于更新用户状态。它接受一个User对象作为参数，并将其状态值组装成SQL语句，使用mysql.update()函数来执行更新操作。如果更新成功，则返回true。

bool UserModel::updateState(User& user) {
   char sql[1024] = {0};
   sprintf(sql, "update user set state = '%s' where id = %d",
           user.getState().c_str(), user.getId());
   if (mysql.update(sql)) {
      return true;
   }
   return false;
}
1
2
3
4
5
6
7
8
9

二、go操作数据库

1、所用到的库

    "database/sql"
    _ "github.com/go-sql-driver/mysql"

1
2
3

---

2、数据库连接

这里定义了一个MySQL结构体，包含了连接数据库、关闭连接、执行SQL语句等功能。在构造函数中，使用sql.Open()打开MySQL数据库，并使用Ping()函数检测连接是否成功

type MySQL struct {
    db *sql.DB
}

func NewMySQL() (*MySQL, error) {
    db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/chat?charset=utf8")
    if err != nil {
        return nil, err
    }

    err = db.Ping()
    if err != nil {
        return nil, err
    }

    return &MySQL{db}, nil
}

func (m *MySQL) Close() error {
    return m.db.Close()
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

3、数据库操作类

Exec()函数用于执行更新（修改、插入或删除）操作，QueryRow()和Query()函数用于执行查询操作。

func (m *MySQL) Exec(query string, args ...interface{}) (sql.Result, error) {
    stmt, err := m.db.Prepare(query)
    if err != nil {
        return nil, err
    }
    defer stmt.Close()

    result, err := stmt.Exec(args...)
    if err != nil {
        return nil, err
    }

    return result, nil
}

func (m *MySQL) QueryRow(query string, args ...interface{}) *sql.Row {
    return m.db.QueryRow(query, args...)
}

func (m *MySQL) Query(query string, args ...interface{}) (*sql.Rows, error) {
    return m.db.Query(query, args...)
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

4、实际操作

这里定义了一个User结构体，表示用户表的一行记录。UserModel结构体包含了数据库操作类的实例，并提供了对用户表进行增加、查询和更新的方法。

在Insert()函数中，使用SQL语句插入一条新记录，并使用LastInsertId()函数获取插入记录的主键ID。

在Query()函数中，使用SQL语句查询一条记录，并将结果封装成一个User对象返回。

在UpdateState()函数中，使用SQL语句更新一条记录的状态。

package model

import (
    "chatroom/mysql"
    "database/sql"
)

type User struct {
    ID       int
    Name     string
    Password string
    State    string
}

type UserModel struct {
    mysql *mysql.MySQL
}

func NewUserModel() (*UserModel, error) {
    db, err := mysql.NewMySQL()
    if err != nil {
        return nil, err
    }

    return &UserModel{db}, nil
}

func (m *UserModel) Close() error {
    return m.mysql.Close()
}

func (m *UserModel) Insert(user *User) (int64, error) {
    query := "insert into user(name, password, state) values (?, ?, ?)"
    result, err := m.mysql.Exec(query, user.Name, user.Password, user.State)
    if err != nil {
        return 0, err
    }

    id, err := result.LastInsertId()
    if err != nil {
        return 0, err
    }

    return id, nil
}

func (m *UserModel) Query(id int) (*User, error) {
    query := "select * from user where id = ?"
    row := m.mysql.QueryRow(query, id)

    user := new(User)
    err := row.Scan(&user.ID, &user.Name, &user.Password, &user.State)
    if err == sql.ErrNoRows {
        return nil, nil
    } else if err != nil {
        return nil, err
    }

    return user, nil
}

func (m *UserModel) UpdateState(user *User) error {
    query := "update user set state = ? where id = ?"
    _, err := m.mysql.Exec(query, user.State, user.ID)
    if err != nil {
        return err
    }

    return nil
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

总结

总结他们在使用的过程中的差异
不同点：

1. C++需要手动管理内存，而Go有垃圾回收机制。
2. C++的MySQL数据库操作库是第三方库，需要单独下载和安装。而Go自带database/sql包实现了对多种数据库的支持，并且支持标准接口，可以很方便地切换不同类型的数据库。
3. C++中使用拼装SQL语句的方式进行数据库操作，而Go可以使用预处理语句，可以提高安全性和效率。
   相同点：
4. 两者都可以通过库来实现与MySQL数据库的连接。
5. 两者都可以执行查询和更新（修改、插入、删除）等SQL操作。
6. 都采用了类似的封装方式，将数据库操作封装成一个类或结构体，并提供了一些简单易用的接口。