查询数据
在 Go 语言中,可以使用 db.Query()、db.QueryRow()和 db.Exec() 函数查询和操作 MySQL 数据库中的数据。
db.Query() 函数用于查询多条记录,返回一个 *sql.Rows 对象。db.QueryRow() 函数用于查询单条记录,返回一个 *sql.Row 对象,类似于 resultset,但是它只返回第一行记录,通常用于查询单个唯一记录。db.Exec() 函数用于执行非查询 SQL 语句,例如 INSERT、UPDATE 和 DELETE,返回一个 sql.Result 对象。
在本例中,我们使用 db.Query() 函数来查询所有记录。我们将使用一个简单的计数器来统计记录的数量,并将每行数据打印到控制台。
rows, err := db.Query("SELECT id, name FROM users") if err != nil { log.Fatal(err) } defer rows.Close() count := 0 for rows.Next() { var id int var name string if err := rows.Scan(&id, &name); err != nil { log.Fatal(err) } fmt.Printf("id=%d, name=%s\n", id, name) count++ } if err := rows.Err(); err != nil { log.Fatal(err) } fmt.Printf("Found %d users\n", count)
必须在检索数据后调用 rows.Close() 函数以释放与 *sql.Rows 关联的数据库资源。同时,代码中使用了 rows.Next() 函数,它返回一个布尔值,指示是否还有更多的行可以进行处理。另外,在这个例子中使用了 rows.Scan() 函数将每行记录的值复制到这个例子中定义的 id 和 name 变量中,然后在控制台中打印每个值。
插入数据
我们也可以使用 Go 语言插入数据到 MySQL 数据库中,最简单的方法使用 db.Exec() 函数。我们可以将插入语句传递到 db.Exec() 函数中,它将以 SQL 语句的形式在 MySQL 中执行。
result, err := db.Exec("INSERT INTO users(name, email) VALUES('John Doe', '[email protected]')") if err != nil { log.Fatal(err) } rowsAffected, err := result.RowsAffected() if err != nil { log.Fatal(err) } fmt.Printf("Inserted %d rows into users table\n", rowsAffected)
我们可以使用 result.RowsAffected() 获取结果集中受影响的行数,并使用该数值在控制台中打印更新数据的数量。