go语言操作mysql数据库

柔光的暖阳◎ 2023-02-20 03:11 17阅读 0赞

MySQL是业界常用的关系型数据库，本文介绍了Go语言如何操作MySQL数据库。

# Go操作MySQL #

## 连接 ##

Go语言中的`database/sql`包提供了保证SQL或类SQL数据库的泛用接口，并不提供具体的数据库驱动。使用`database/sql`包时必须注入（至少）一个数据库驱动。

我们常用的数据库基本上都有完整的第三方实现。例如：[MySQL驱动][MySQL]

### 下载依赖 ###

go get -u github.com/go-sql-driver/mysql

### 使用MySQL驱动 ###

func Open(driverName, dataSourceName string) (*DB, error)

Open打开一个dirverName指定的数据库，dataSourceName指定数据源，一般至少包括数据库文件名和其它连接必要的信息。

import (
    	"database/sql"
    
    	_ "github.com/go-sql-driver/mysql"
    )
    
    func main() { 
       // DSN:Data Source Name
    	dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
    	db, err := sql.Open("mysql", dsn)
    	if err != nil { 
    		panic(err)
    	}
    	defer db.Close()  // 注意这行代码要写在上面err判断的下面
    }

**思考题**： 为什么上面代码中的`defer db.Close()`语句不应该写在`if err != nil`的前面呢？

### 初始化连接 ###

Open函数可能只是验证其参数格式是否正确，实际上并不创建与数据库的连接。如果要检查数据源的名称是否真实有效，应该调用Ping方法。

返回的DB对象可以安全地被多个goroutine并发使用，并且维护其自己的空闲连接池。因此，Open函数应该仅被调用一次，很少需要关闭这个DB对象。

// 定义一个全局对象db
    var db *sql.DB
    
    // 定义一个初始化数据库的函数
    func initDB() (err error) { 
    	// DSN:Data Source Name
    	dsn := "user:password@tcp(127.0.0.1:3306)/sql_test?charset=utf8mb4&parseTime=True"
    	// 不会校验账号密码是否正确
    	// 注意！！！这里不要使用:=，我们是给全局变量赋值，然后在main函数中使用全局变量db
    	db, err = sql.Open("mysql", dsn)
    	if err != nil { 
    		return err
    	}
    	// 尝试与数据库建立连接（校验dsn是否正确）
    	err = db.Ping()
    	if err != nil { 
    		return err
    	}
    	return nil
    }
    
    func main() { 
    	err := initDB() // 调用输出化数据库的函数
    	if err != nil { 
    		fmt.Printf("init db failed,err:%v\n", err)
    		return
    	}
    }

其中`sql.DB`是表示连接的数据库对象（结构体实例），它保存了连接数据库相关的所有信息。它内部维护着一个具有零到多个底层连接的连接池，它可以安全地被多个goroutine同时使用。

### SetMaxOpenConns ###

func (db *DB) SetMaxOpenConns(n int)

`SetMaxOpenConns`设置与数据库建立连接的最大数目。 如果n大于0且小于最大闲置连接数，会将最大闲置连接数减小到匹配最大开启连接数的限制。 如果n<=0，不会限制最大开启连接数，默认为0（无限制）。

### SetMaxIdleConns ###

func (db *DB) SetMaxIdleConns(n int)

SetMaxIdleConns设置连接池中的最大闲置连接数。 如果n大于最大开启连接数，则新的最大闲置连接数会减小到匹配最大开启连接数的限制。 如果n<=0，不会保留闲置连接。

## CRUD ##

### 建库建表 ###

我们先在MySQL中创建一个名为`sql_test`的数据库

CREATE DATABASE sql_test;

进入该数据库:

use sql_test;

执行以下命令创建一张用于测试的数据表：

CREATE TABLE `user` (
        `id` BIGINT(20) NOT NULL AUTO_INCREMENT,
        `name` VARCHAR(20) DEFAULT '',
        `age` INT(11) DEFAULT '0',
        PRIMARY KEY(`id`)
    )ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4;

### 查询 ###

为了方便查询，我们事先定义好一个结构体来存储user表的数据。

type user struct { 
    	id   int
    	age  int
    	name string
    }

#### 单行查询 ####

单行查询`db.QueryRow()`执行一次查询，并期望返回最多一行结果（即Row）。QueryRow总是返回非nil的值，直到返回值的Scan方法被调用时，才会返回被延迟的错误。（如：未找到结果）

func (db *DB) QueryRow(query string, args ...interface{ }) *Row

具体示例代码：

// 查询单条数据示例
    func queryRowDemo() { 
    	sqlStr := "select id, name, age from user where id=?"
    	var u user
    	// 非常重要：确保QueryRow之后调用Scan方法，否则持有的数据库链接不会被释放
    	err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name, &u.age)
    	if err != nil { 
    		fmt.Printf("scan failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
    }

#### 多行查询 ####

多行查询`db.Query()`执行一次查询，返回多行结果（即Rows），一般用于执行select命令。参数args表示query中的占位参数。

func (db *DB) Query(query string, args ...interface{ }) (*Rows, error)

具体示例代码：

// 查询多条数据示例
    func queryMultiRowDemo() { 
    	sqlStr := "select id, name, age from user where id > ?"
    	rows, err := db.Query(sqlStr, 0)
    	if err != nil { 
    		fmt.Printf("query failed, err:%v\n", err)
    		return
    	}
    	// 非常重要：关闭rows释放持有的数据库链接
    	defer rows.Close()
    
    	// 循环读取结果集中的数据
    	for rows.Next() { 
    		var u user
    		err := rows.Scan(&u.id, &u.name, &u.age)
    		if err != nil { 
    			fmt.Printf("scan failed, err:%v\n", err)
    			return
    		}
    		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
    	}
    }

### 插入数据 ###

插入、更新和删除操作都使用`Exec`方法。

func (db *DB) Exec(query string, args ...interface{ }) (Result, error)

Exec执行一次命令（包括查询、删除、更新、插入等），返回的Result是对已执行的SQL命令的总结。参数args表示query中的占位参数。

具体插入数据示例代码如下：

// 插入数据
    func insertRowDemo() { 
    	sqlStr := "insert into user(name, age) values (?,?)"
    	ret, err := db.Exec(sqlStr, "王五", 38)
    	if err != nil { 
    		fmt.Printf("insert failed, err:%v\n", err)
    		return
    	}
    	theID, err := ret.LastInsertId() // 新插入数据的id
    	if err != nil { 
    		fmt.Printf("get lastinsert ID failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("insert success, the id is %d.\n", theID)
    }

### 更新数据 ###

具体更新数据示例代码如下：

// 更新数据
    func updateRowDemo() { 
    	sqlStr := "update user set age=? where id = ?"
    	ret, err := db.Exec(sqlStr, 39, 3)
    	if err != nil { 
    		fmt.Printf("update failed, err:%v\n", err)
    		return
    	}
    	n, err := ret.RowsAffected() // 操作影响的行数
    	if err != nil { 
    		fmt.Printf("get RowsAffected failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("update success, affected rows:%d\n", n)
    }

### 删除数据 ###

具体删除数据的示例代码如下：

// 删除数据
    func deleteRowDemo() { 
    	sqlStr := "delete from user where id = ?"
    	ret, err := db.Exec(sqlStr, 3)
    	if err != nil { 
    		fmt.Printf("delete failed, err:%v\n", err)
    		return
    	}
    	n, err := ret.RowsAffected() // 操作影响的行数
    	if err != nil { 
    		fmt.Printf("get RowsAffected failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("delete success, affected rows:%d\n", n)
    }

## MySQL预处理 ##

### 什么是预处理？ ###

普通SQL语句执行过程：

1.  客户端对SQL语句进行占位符替换得到完整的SQL语句。
2.  客户端发送完整SQL语句到MySQL服务端
3.  MySQL服务端执行完整的SQL语句并将结果返回给客户端。

预处理执行过程：

1.  把SQL语句分成两部分，命令部分与数据部分。
2.  先把命令部分发送给MySQL服务端，MySQL服务端进行SQL预处理。
3.  然后把数据部分发送给MySQL服务端，MySQL服务端对SQL语句进行占位符替换。
4.  MySQL服务端执行完整的SQL语句并将结果返回给客户端。

### 为什么要预处理？ ###

1.  优化MySQL服务器重复执行SQL的方法，可以提升服务器性能，提前让服务器编译，一次编译多次执行，节省后续编译的成本。
2.  避免SQL注入问题。

### Go实现MySQL预处理 ###

`database/sql`中使用下面的`Prepare`方法来实现预处理操作。

func (db *DB) Prepare(query string) (*Stmt, error)

`Prepare`方法会先将sql语句发送给MySQL服务端，返回一个准备好的状态用于之后的查询和命令。返回值可以同时执行多个查询和命令。

查询操作的预处理示例代码如下：

// 预处理查询示例
    func prepareQueryDemo() { 
    	sqlStr := "select id, name, age from user where id > ?"
    	stmt, err := db.Prepare(sqlStr)
    	if err != nil { 
    		fmt.Printf("prepare failed, err:%v\n", err)
    		return
    	}
    	defer stmt.Close()
    	rows, err := stmt.Query(0)
    	if err != nil { 
    		fmt.Printf("query failed, err:%v\n", err)
    		return
    	}
    	defer rows.Close()
    	// 循环读取结果集中的数据
    	for rows.Next() { 
    		var u user
    		err := rows.Scan(&u.id, &u.name, &u.age)
    		if err != nil { 
    			fmt.Printf("scan failed, err:%v\n", err)
    			return
    		}
    		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
    	}
    }

插入、更新和删除操作的预处理十分类似，这里以插入操作的预处理为例：

// 预处理插入示例
    func prepareInsertDemo() { 
    	sqlStr := "insert into user(name, age) values (?,?)"
    	stmt, err := db.Prepare(sqlStr)
    	if err != nil { 
    		fmt.Printf("prepare failed, err:%v\n", err)
    		return
    	}
    	defer stmt.Close()
    	_, err = stmt.Exec("小王子", 18)
    	if err != nil { 
    		fmt.Printf("insert failed, err:%v\n", err)
    		return
    	}
    	_, err = stmt.Exec("沙河娜扎", 18)
    	if err != nil { 
    		fmt.Printf("insert failed, err:%v\n", err)
    		return
    	}
    	fmt.Println("insert success.")
    }

### SQL注入问题 ###

**我们任何时候都不应该自己拼接SQL语句！**

这里我们演示一个自行拼接SQL语句的示例，编写一个根据name字段查询user表的函数如下：

// sql注入示例
    func sqlInjectDemo(name string) { 
    	sqlStr := fmt.Sprintf("select id, name, age from user where name='%s'", name)
    	fmt.Printf("SQL:%s\n", sqlStr)
    	var u user
    	err := db.QueryRow(sqlStr).Scan(&u.id, &u.name, &u.age)
    	if err != nil { 
    		fmt.Printf("exec failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("user:%#v\n", u)
    }

此时以下输入字符串都可以引发SQL注入问题：

sqlInjectDemo("xxx' or 1=1#")
    sqlInjectDemo("xxx' union select * from user #")
    sqlInjectDemo("xxx' and (select count(*) from user) <10 #")

\*\*补充：\*\*不同的数据库中，SQL语句使用的占位符语法不尽相同。

<table> 
 <thead> 
  <tr> 
   <th align="center">数据库</th> 
   <th align="center">占位符语法</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">MySQL</td> 
   <td align="center"><code>?</code></td> 
  </tr> 
  <tr> 
   <td align="center">PostgreSQL</td> 
   <td align="center"><code>$1</code>, <code>$2</code>等</td> 
  </tr> 
  <tr> 
   <td align="center">SQLite</td> 
   <td align="center"><code>?</code> 和<code>$1</code></td> 
  </tr> 
  <tr> 
   <td align="center">Oracle</td> 
   <td align="center"><code>:name</code></td> 
  </tr> 
 </tbody> 
</table>

## Go实现MySQL事务 ##

### 什么是事务？ ###

事务：一个最小的不可再分的工作单元；通常一个事务对应一个完整的业务(例如银行账户转账业务，该业务就是一个最小的工作单元)，同时这个完整的业务需要执行多次的DML(insert、update、delete)语句共同联合完成。A转账给B，这里面就需要执行两次update操作。

在MySQL中只有使用了`Innodb`数据库引擎的数据库或表才支持事务。事务处理可以用来维护数据库的完整性，保证成批的SQL语句要么全部执行，要么全部不执行。

### 事务的ACID ###

通常事务必须满足4个条件（ACID）：原子性（Atomicity，或称不可分割性）、一致性（Consistency）、隔离性（Isolation，又称独立性）、持久性（Durability）。

<table> 
 <thead> 
  <tr> 
   <th align="center">条件</th> 
   <th align="center">解释</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">原子性</td> 
   <td align="center">一个事务（transaction）中的所有操作，要么全部完成，要么全部不完成，不会结束在中间某个环节。事务在执行过程中发生错误，会被回滚（Rollback）到事务开始前的状态，就像这个事务从来没有执行过一样。</td> 
  </tr> 
  <tr> 
   <td align="center">一致性</td> 
   <td align="center">在事务开始之前和事务结束以后，数据库的完整性没有被破坏。这表示写入的资料必须完全符合所有的预设规则，这包含资料的精确度、串联性以及后续数据库可以自发性地完成预定的工作。</td> 
  </tr> 
  <tr> 
   <td align="center">隔离性</td> 
   <td align="center">数据库允许多个并发事务同时对其数据进行读写和修改的能力，隔离性可以防止多个事务并发执行时由于交叉执行而导致数据的不一致。事务隔离分为不同级别，包括读未提交（Read uncommitted）、读提交（read committed）、可重复读（repeatable read）和串行化（Serializable）。</td> 
  </tr> 
  <tr> 
   <td align="center">持久性</td> 
   <td align="center">事务处理结束后，对数据的修改就是永久的，即便系统故障也不会丢失。</td> 
  </tr> 
 </tbody> 
</table>

### 事务相关方法 ###

Go语言中使用以下三个方法实现MySQL中的事务操作。 开始事务

func (db *DB) Begin() (*Tx, error)

提交事务

func (tx *Tx) Commit() error

回滚事务

func (tx *Tx) Rollback() error

### 事务示例 ###

下面的代码演示了一个简单的事务操作，该事物操作能够确保两次更新操作要么同时成功要么同时失败，不会存在中间状态。

// 事务操作示例
    func transactionDemo() { 
    	tx, err := db.Begin() // 开启事务
    	if err != nil { 
    		if tx != nil { 
    			tx.Rollback() // 回滚
    		}
    		fmt.Printf("begin trans failed, err:%v\n", err)
    		return
    	}
    	sqlStr1 := "Update user set age=30 where id=?"
    	ret1, err := tx.Exec(sqlStr1, 2)
    	if err != nil { 
    		tx.Rollback() // 回滚
    		fmt.Printf("exec sql1 failed, err:%v\n", err)
    		return
    	}
    	affRow1, err := ret1.RowsAffected()
    	if err != nil { 
    		tx.Rollback() // 回滚
    		fmt.Printf("exec ret1.RowsAffected() failed, err:%v\n", err)
    		return
    	}
    
    	sqlStr2 := "Update user set age=40 where id=?"
    	ret2, err := tx.Exec(sqlStr2, 3)
    	if err != nil { 
    		tx.Rollback() // 回滚
    		fmt.Printf("exec sql2 failed, err:%v\n", err)
    		return
    	}
    	affRow2, err := ret2.RowsAffected()
    	if err != nil { 
    		tx.Rollback() // 回滚
    		fmt.Printf("exec ret1.RowsAffected() failed, err:%v\n", err)
    		return
    	}
    
    	fmt.Println(affRow1, affRow2)
    	if affRow1 == 1 && affRow2 == 1 { 
    		fmt.Println("事务提交啦...")
    		tx.Commit() // 提交事务
    	} else { 
    		tx.Rollback()
    		fmt.Println("事务回滚啦...")
    	}
    
    	fmt.Println("exec trans success!")
    }

[更强大、更好用的sqlx库][sqlx]

在项目中我们通常可能会使用`database/sql`连接MySQL数据库。本文借助使用`sqlx`实现批量插入数据的例子，介绍了`sqlx`中可能被你忽视了的`sqlx.In`和`DB.NamedExec`方法。

## sqlx介绍 ##

在项目中我们通常可能会使用`database/sql`连接MySQL数据库。`sqlx`可以认为是Go语言内置`database/sql`的超集，它在优秀的内置`database/sql`基础上提供了一组扩展。这些扩展中除了大家常用来查询的`Get(dest interface{}, ...) error`和`Select(dest interface{}, ...) error`外还有很多其他强大的功能。

## 安装sqlx ##

go get github.com/jmoiron/sqlx

## 基本使用 ##

### 连接数据库 ###

var db *sqlx.DB
    
    func initDB() (err error) { 
    	dsn := "user:password@tcp(127.0.0.1:3306)/sql_test?charset=utf8mb4&parseTime=True"
    	// 也可以使用MustConnect连接不成功就panic
    	db, err = sqlx.Connect("mysql", dsn)
    	if err != nil { 
    		fmt.Printf("connect DB failed, err:%v\n", err)
    		return
    	}
    	db.SetMaxOpenConns(20)
    	db.SetMaxIdleConns(10)
    	return
    }

### 查询 ###

查询单行数据示例代码如下：

// 查询单条数据示例
    func queryRowDemo() { 
    	sqlStr := "select id, name, age from user where id=?"
    	var u user
    	err := db.Get(&u, sqlStr, 1)
    	if err != nil { 
    		fmt.Printf("get failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("id:%d name:%s age:%d\n", u.ID, u.Name, u.Age)
    }

查询多行数据示例代码如下：

// 查询多条数据示例
    func queryMultiRowDemo() { 
    	sqlStr := "select id, name, age from user where id > ?"
    	var users []user
    	err := db.Select(&users, sqlStr, 0)
    	if err != nil { 
    		fmt.Printf("query failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("users:%#v\n", users)
    }

### 插入、更新和删除 ###

sqlx中的exec方法与原生sql中的exec使用基本一致：

// 插入数据
    func insertRowDemo() { 
    	sqlStr := "insert into user(name, age) values (?,?)"
    	ret, err := db.Exec(sqlStr, "沙河小王子", 19)
    	if err != nil { 
    		fmt.Printf("insert failed, err:%v\n", err)
    		return
    	}
    	theID, err := ret.LastInsertId() // 新插入数据的id
    	if err != nil { 
    		fmt.Printf("get lastinsert ID failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("insert success, the id is %d.\n", theID)
    }
    
    // 更新数据
    func updateRowDemo() { 
    	sqlStr := "update user set age=? where id = ?"
    	ret, err := db.Exec(sqlStr, 39, 6)
    	if err != nil { 
    		fmt.Printf("update failed, err:%v\n", err)
    		return
    	}
    	n, err := ret.RowsAffected() // 操作影响的行数
    	if err != nil { 
    		fmt.Printf("get RowsAffected failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("update success, affected rows:%d\n", n)
    }
    
    // 删除数据
    func deleteRowDemo() { 
    	sqlStr := "delete from user where id = ?"
    	ret, err := db.Exec(sqlStr, 6)
    	if err != nil { 
    		fmt.Printf("delete failed, err:%v\n", err)
    		return
    	}
    	n, err := ret.RowsAffected() // 操作影响的行数
    	if err != nil { 
    		fmt.Printf("get RowsAffected failed, err:%v\n", err)
    		return
    	}
    	fmt.Printf("delete success, affected rows:%d\n", n)
    }

### NamedExec ###

`DB.NamedExec`方法用来绑定SQL语句与结构体或map中的同名字段。

func insertUserDemo()(err error){ 
    	sqlStr := "INSERT INTO user (name,age) VALUES (:name,:age)"
    	_, err = db.NamedExec(sqlStr,
    		map[string]interface{ }{ 
    			"name": "七米",
    			"age": 28,
    		})
    	return
    }

### NamedQuery ###

与`DB.NamedExec`同理，这里是支持查询。

func namedQuery(){ 
    	sqlStr := "SELECT * FROM user WHERE name=:name"
    	// 使用map做命名查询
    	rows, err := db.NamedQuery(sqlStr, map[string]interface{ }{ "name": "七米"})
    	if err != nil { 
    		fmt.Printf("db.NamedQuery failed, err:%v\n", err)
    		return
    	}
    	defer rows.Close()
    	for rows.Next(){ 
    		var u user
    		err := rows.StructScan(&u)
    		if err != nil { 
    			fmt.Printf("scan failed, err:%v\n", err)
    			continue
    		}
    		fmt.Printf("user:%#v\n", u)
    	}
    
    	u := user{ 
    		Name: "七米",
    	}
    	// 使用结构体命名查询，根据结构体字段的 db tag进行映射
    	rows, err = db.NamedQuery(sqlStr, u)
    	if err != nil { 
    		fmt.Printf("db.NamedQuery failed, err:%v\n", err)
    		return
    	}
    	defer rows.Close()
    	for rows.Next(){ 
    		var u user
    		err := rows.StructScan(&u)
    		if err != nil { 
    			fmt.Printf("scan failed, err:%v\n", err)
    			continue
    		}
    		fmt.Printf("user:%#v\n", u)
    	}
    }

### 事务操作 ###

对于事务操作，我们可以使用`sqlx`中提供的`db.Beginx()`和`tx.Exec()`方法。示例代码如下：

func transactionDemo2()(err error) { 
    	tx, err := db.Beginx() // 开启事务
    	if err != nil { 
    		fmt.Printf("begin trans failed, err:%v\n", err)
    		return err
    	}
    	defer func() { 
    		if p := recover(); p != nil { 
    			tx.Rollback()
    			panic(p) // re-throw panic after Rollback
    		} else if err != nil { 
    			fmt.Println("rollback")
    			tx.Rollback() // err is non-nil; don't change it
    		} else { 
    			err = tx.Commit() // err is nil; if Commit returns error update err
    			fmt.Println("commit")
    		}
    	}()
    
    	sqlStr1 := "Update user set age=20 where id=?"
    
    	rs, err := tx.Exec(sqlStr1, 1)
    	if err!= nil{ 
    		return err
    	}
    	n, err := rs.RowsAffected()
    	if err != nil { 
    		return err
    	}
    	if n != 1 { 
    		return errors.New("exec sqlStr1 failed")
    	}
    	sqlStr2 := "Update user set age=50 where i=?"
    	rs, err = tx.Exec(sqlStr2, 5)
    	if err!=nil{ 
    		return err
    	}
    	n, err = rs.RowsAffected()
    	if err != nil { 
    		return err
    	}
    	if n != 1 { 
    		return errors.New("exec sqlStr1 failed")
    	}
    	return err
    }

## sqlx.In ##

`sqlx.In`是`sqlx`提供的一个非常方便的函数。

### sqlx.In的批量插入示例 ###

#### 表结构 ####

为了方便演示插入数据操作，这里创建一个`user`表，表结构如下：

#### 结构体 ####

定义一个`user`结构体，字段通过tag与数据库中user表的列一致。

type User struct { 
    	Name string `db:"name"`
    	Age  int    `db:"age"`
    }

#### bindvars（绑定变量） ####

查询占位符`?`在内部称为**bindvars（查询占位符）**,它非常重要。你应该始终使用它们向数据库发送值，因为它们可以防止SQL注入攻击。`database/sql`不尝试对查询文本进行任何验证；它与编码的参数一起按原样发送到服务器。除非驱动程序实现一个特殊的接口，否则在执行之前，查询是在服务器上准备的。因此`bindvars`是特定于数据库的:

*  MySQL中使用`?`
 *  PostgreSQL使用枚举的`$1`、`$2`等bindvar语法
 *  SQLite中`?`和`$1`的语法都支持
 *  Oracle中使用`:name`的语法

`bindvars`的一个常见误解是，它们用来在sql语句中插入值。它们其实仅用于参数化，不允许更改SQL语句的结构。例如，使用`bindvars`尝试参数化列或表名将不起作用：

// ？不能用来插入表名（做SQL语句中表名的占位符）
    db.Query("SELECT * FROM ?", "mytable")
     
    // ？也不能用来插入列名（做SQL语句中列名的占位符）
    db.Query("SELECT ?, ? FROM people", "name", "location")

#### 自己拼接语句实现批量插入 ####

比较笨，但是很好理解。就是有多少个User就拼接多少个`(?, ?)`。

// BatchInsertUsers 自行构造批量插入的语句
    func BatchInsertUsers(users []*User) error { 
    	// 存放 (?, ?) 的slice
    	valueStrings := make([]string, 0, len(users))
    	// 存放values的slice
    	valueArgs := make([]interface{ }, 0, len(users) * 2)
    	// 遍历users准备相关数据
    	for _, u := range users { 
    		// 此处占位符要与插入值的个数对应
    		valueStrings = append(valueStrings, "(?, ?)")
    		valueArgs = append(valueArgs, u.Name)
    		valueArgs = append(valueArgs, u.Age)
    	}
    	// 自行拼接要执行的具体语句
    	stmt := fmt.Sprintf("INSERT INTO user (name, age) VALUES %s",
    		strings.Join(valueStrings, ","))
    	_, err := DB.Exec(stmt, valueArgs...)
    	return err
    }

#### 使用sqlx.In实现批量插入 ####

前提是需要我们的结构体实现`driver.Valuer`接口：

func (u User) Value() (driver.Value, error) { 
    	return []interface{ }{ u.Name, u.Age}, nil
    }

使用`sqlx.In`实现批量插入代码如下：

// BatchInsertUsers2 使用sqlx.In帮我们拼接语句和参数, 注意传入的参数是[]interface{}
    func BatchInsertUsers2(users []interface{ }) error { 
    	query, args, _ := sqlx.In(
    		"INSERT INTO user (name, age) VALUES (?), (?), (?)",
    		users..., // 如果arg实现了 driver.Valuer, sqlx.In 会通过调用 Value()来展开它
    	)
    	fmt.Println(query) // 查看生成的querystring
    	fmt.Println(args)  // 查看生成的args
    	_, err := DB.Exec(query, args...)
    	return err
    }

#### 使用NamedExec实现批量插入 ####

**注意** ：该功能目前有人已经推了[\#285 PR][285 PR]，但是作者还没有发`release`，所以想要使用下面的方法实现批量插入需要暂时使用`master`分支的代码：

在项目目录下执行以下命令下载并使用`master`分支代码：

go get github.com/jmoiron/sqlx@master

使用`NamedExec`实现批量插入的代码如下：

// BatchInsertUsers3 使用NamedExec实现批量插入
    func BatchInsertUsers3(users []*User) error { 
    	_, err := DB.NamedExec("INSERT INTO user (name, age) VALUES (:name, :age)", users)
    	return err
    }

把上面三种方法综合起来试一下：

func main() { 
    	err := initDB()
    	if err != nil { 
    		panic(err)
    	}
    	defer DB.Close()
    	u1 := User{ Name: "七米", Age: 18}
    	u2 := User{ Name: "q1mi", Age: 28}
    	u3 := User{ Name: "小王子", Age: 38}
    
    	// 方法1
    	users := []*User{ &u1, &u2, &u3}
    	err = BatchInsertUsers(users)
    	if err != nil { 
    		fmt.Printf("BatchInsertUsers failed, err:%v\n", err)
    	}
    
    	// 方法2
    	users2 := []interface{ }{ u1, u2, u3}
    	err = BatchInsertUsers2(users2)
    	if err != nil { 
    		fmt.Printf("BatchInsertUsers2 failed, err:%v\n", err)
    	}
    
    	// 方法3
    	users3 := []*User{ &u1, &u2, &u3}
    	err = BatchInsertUsers3(users3)
    	if err != nil { 
    		fmt.Printf("BatchInsertUsers3 failed, err:%v\n", err)
    	}
    }

### sqlx.In的查询示例 ###

关于`sqlx.In`这里再补充一个用法，在`sqlx`查询语句中实现In查询和FIND\_IN\_SET函数。即实现`SELECT * FROM user WHERE id in (3, 2, 1);`和`SELECT * FROM user WHERE id in (3, 2, 1) ORDER BY FIND_IN_SET(id, '3,2,1');`。

#### in查询 ####

查询id在给定id集合中的数据。

// QueryByIDs 根据给定ID查询
    func QueryByIDs(ids []int)(users []User, err error){ 
    	// 动态填充id
    	query, args, err := sqlx.In("SELECT name, age FROM user WHERE id IN (?)", ids)
    	if err != nil { 
    		return
    	}
    	// sqlx.In 返回带 `?` bindvar的查询语句, 我们使用Rebind()重新绑定它
    	query = DB.Rebind(query)
    
    	err = DB.Select(&users, query, args...)
    	return
    }

#### in查询和FIND\_IN\_SET函数 ####

查询id在给定id集合的数据并维持给定id集合的顺序。

// QueryAndOrderByIDs 按照指定id查询并维护顺序
    func QueryAndOrderByIDs(ids []int)(users []User, err error){ 
    	// 动态填充id
    	strIDs := make([]string, 0, len(ids))
    	for _, id := range ids { 
    		strIDs = append(strIDs, fmt.Sprintf("%d", id))
    	}
    	query, args, err := sqlx.In("SELECT name, age FROM user WHERE id IN (?) ORDER BY FIND_IN_SET(id, ?)", ids, strings.Join(strIDs, ","))
    	if err != nil { 
    		return
    	}
    
    	// sqlx.In 返回带 `?` bindvar的查询语句, 我们使用Rebind()重新绑定它
    	query = DB.Rebind(query)
    
    	err = DB.Select(&users, query, args...)
    	return
    }

当然，在这个例子里面你也可以先使用`IN`查询，然后通过代码按给定的ids对查询结果进行排序。

[MySQL]: https://github.com/go-sql-driver/mysql
[sqlx]: https://www.liwenzhou.com/posts/Go/sqlx/
[285 PR]: https://github.com/jmoiron/sqlx/pull/285