MySQL golang gorm访问底层mysql查询|极客笔记

MySQL golang gorm访问底层mysql查询

在使用golang gorm操作MySQL数据库时，常常需要使用底层mysql查询执行一些高级操作。下面我们来介绍如何通过golang gorm访问底层mysql查询。

阅读更多：MySQL 教程

1. 执行原始查询

使用gorm.DB的Raw方法可以执行原始查询。

示例代码：

db.Raw("SELECT * FROM users WHERE name = ?", "test").Scan(&users)

上述代码实现了一个简单的SELECT查询，将结果赋值给users。

2. 执行批量插入或更新

使用gorm.DB的Clauses方法可以执行批量插入或更新。

示例代码：

sql := "INSERT INTO users (name, age) VALUES (?, ?) ON DUPLICATE KEY UPDATE age = VALUES(age)"
db.Clauses(clause.Insert{Modifier: "VALUES (?, ?)"}, "test", 18).Clauses(clause.OnConflict{UpdateAll: true}).Exec(sql)

上述代码实现了一个批量插入或更新语句，如果name存在，则更新age的值，否则插入新的数据。

3. 执行存储过程

使用gorm.DB的Exec方法可以执行存储过程。

示例代码：

db.Exec("CALL sp_test(?, ?)", "test", 18)

上述代码实现了一个存储过程调用，将参数传递给存储过程并执行。

4. 执行事务

使用gorm.DB的Transaction方法可以执行事务。

示例代码：

tx := db.Begin()
defer func() {
    if err := recover(); err != nil {
        tx.Rollback()
    } else {
        tx.Commit()
    }
}()

// 在事务内执行原始查询、更新操作等
tx.Raw("SELECT * FROM users WHERE name = ?", "test").Scan(&users)
tx.Model(&User{}).Where("age = ?", 18).Update("name", "test2")

上述代码实现了一个基本的事务操作，如果出现错误，则回滚事务，否则提交事务。