1、常用方法
func Open(driverName, dataSourceName string) (*DB, error)
driverName 参数为数据库驱动名称
dataSourceName 连接参数，
参数格式：user:password@tcp(host:port)/dbname?charset=utf8
func (db *DB) Prepare(query string) (*Stmt, error)
Prepare为后续查询或执行操作创建一个准备SQL
func (s *Stmt) Exec(args ...interface{}) (Result, error)
使用给定参数执行准备的SQL语句
func (s *Stmt) Query(args ...interface{}) (*Rows, error)
使用给定参数执行准备的SQL查询语句
func (db *DB) Exec(query string, args ...interface{}) (Result, error)
执行SQL操作，query为SQL语句，可以接收可变参数，用于填充SQL语句的某些字段值。
func (db *DB) Query(query string, args ...interface{}) (*Rows, error)
执行SQL查询操作，可以接收多个参数
2、常用操作
package main
?
import (
? ?"database/sql"
? ?"fmt"
?
? ?_ "github.com/go-sql-driver/mysql"
)
?
func errorHandler(err error) {
? ?if err != nil {
? ? ? fmt.Println(err.Error())
? ?}
}
?
var (
? ?CREATE_TABLE = "CREATE TABLE student(" +
? ? ? "sid INT(10) NOT NULL AUTO_INCREMENT," +
? ? ? "sname VARCHAR(64) NULL DEFAULT NULL," +
? ? ? "age INT(10) DEFAULT NULL,PRIMARY KEY (sid))" +
? ? ? "ENGINE=InnoDB DEFAULT CHARSET=utf8;"
)
?
// 建立数据库连接
func setupConnect() *sql.DB {
? ?db, err := sql.Open("mysql", "root:xxxxxx@tcp(118.24.159.133:3306)/student?charset=utf8")
? ?errorHandler(err)
? ?return db
}
?
// 创建表
func CreateTable(db *sql.DB, sql string) {
? ?_, err := db.Exec(sql)
? ?errorHandler(err)
}
?
var INSERT_DATA = `INSERT INTO student(sid,sname,age) VALUES(?,?,?);`
?
// 插入数据
func Insert(db *sql.DB) {
? ?db.Exec(INSERT_DATA, 1, "唐僧", 30)
}
?
var UPDATE_DATA = `UPDATE student SET age=28 WHERE sname="唐僧";`
?
// 修改数据
func Update(db *sql.DB) {
? ?db.Exec(UPDATE_DATA)
?
}
?
var DELETE_DATA = `DELETE FROM student WHERE age>=30`
?
// 删除记录
func Delete(db *sql.DB) {
? ?db.Exec(DELETE_DATA)
}
?
var DELETE_TABLE = `DROP TABLE student;`
?
// 删除表
func DeleteTable(db *sql.DB) {
? ?db.Exec(DELETE_TABLE)
}
?
var QUERY_DATA = `SELECT * FROM student;`
?
// 查询数据
func Query(db *sql.DB) {
? ?rows, err := db.Query(QUERY_DATA)
? ?if err != nil {
? ? ? fmt.Println(err)
? ?}
? ?for rows.Next() {
? ? ? var name string
? ? ? var id int
? ? ? var age int
? ? ? if err := rows.Scan(&id, &name, &age); err != nil {
? ? ? ? ?fmt.Println(err)
? ? ? }
? ? ? fmt.Printf("%s is %d\n", name, age)
? ?}
}
?
func main() {
? ?// 建立数据连接
? ?db := setupConnect()
? ?// 创建数据库表
? ?CreateTable(db, CREATE_TABLE)
? ?// 插入数据
? ?Insert(db)
? ?// 查询数据
? ?Query(db)
? ?// 删除数据
? ?Delete(db)
? ?// 插入数据
? ?Insert(db)
? ?// 修改数据
? ?Update(db)
? ?// 查询数据
? ?Query(db)
? ?// 删除表
? ?DeleteTable(db)
? ?// 关闭数据库连接
? ?db.Close()
}
|
