- 数据库
- Go 中的 MySql 和 ORM
### Mysql 基础
在你的终端输入如下代码：
/usr/local/mysql/bin/mysql -u root -p
执行命令之后，输入你的 Mysql 数据库密码，成功之后显示：
Enter password:
Welcome to the MySQL monitor. Commands end with ; or \g.
Your MySQL connection id is 19
Server version: 5.7.17 MySQL Community Server (GPL)
Copyright (c) 2000, 2016, Oracle and/or its affiliates. All rights reserved.
Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.
Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
mysql>
创建 test 数据库：
mysql> create database test;
Query OK, 1 row affected (0.00 sec)
显示所有存在的数据库：
mysql> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| DB |
| mysql |
| performance_schema |
| sys |
| test |
+--------------------+
6 rows in set (0.00 sec)
可以看到 test 数据库已经成功创建。接下来我们在 test 数据库创建两张表：userinfo 和 userdetail。首先切换到 test 数据库。我们先看看当前正在使用的数据库：
mysql> select database()
-> ;
+------------+
| database() |
+------------+
| test |
+------------+
1 row in set (0.00 sec)
切换操作：
mysql> use test;
Database changed
如上，我们就成功切换到 test 数据库中了，接下来我们创建两张表啦：
mysql> CREATE TABLE `userinfo` (
-> `uid` INT(10) NOT NULL AUTO_INCREMENT,
-> `username` VARCHAR(64) NULL DEFAULT NULL,
-> `departname` VARCHAR(64) NULL DEFAULT NULL,
-> `created` DATE NULL DEFAULT NULL,
-> PRIMARY KEY (`uid`)
-> );
mysql> CREATE TABLE `userdetail` (
-> `uid` INT(10) NOT NULL DEFAULT '0',
-> `intro` TEXT NULL,
-> `profile` TEXT NULL,
-> PRIMARY KEY (`uid`)
-> );
Query OK, 0 rows affected (0.02 sec)
查看表是否显示成功：
mysql> show tables;
+----------------+
| Tables_in_test |
+----------------+
| userdetail |
| userinfo |
+----------------+
2 rows in set (0.00 sec)
我们想看看所建表的结构的话：
mysql> desc userinfo;
+------------+-------------+------+-----+---------+----------------+
| Field | Type | Null | Key | Default | Extra |
+------------+-------------+------+-----+---------+----------------+
| uid | int(10) | NO | PRI | NULL | auto_increment |
| username | varchar(64) | YES | | NULL | |
| departname | varchar(64) | YES | | NULL | |
| created | date | YES | | NULL | |
+------------+-------------+------+-----+---------+----------------+
4 rows in set (0.00 sec)
向表中插入数据，并显示出来：
mysql> insert into userdetail VALUES ('2','Hello world', "I am allenuw");
Query OK, 1 row affected (0.00 sec)
mysql> select * from userdetail;
+-----+-------------+--------------+
| uid | intro | profile |
+-----+-------------+--------------+
| 2 | Hello world | I am allenuw |
+-----+-------------+--------------+
1 row in set (0.00 sec)
上面就是 Mysql 数据表最基本的操作了，还有很多要学习，其他的话大家 Google 一下就好了。接下来我们讲述 Go 中如何操作 Mysql 数据库。
Golang 操作 Mysql
Go没有内置的驱动支持任何的数据库，但是Go定义了database/sql接口，用户可以基于驱动接口开发相应数据库的驱动。这一节来尝试与喜爱 mysql 的驱动
go get github.com/go-sql-driver/mysql
安装好 mysql 驱动之后，我们按照上述的步骤在终端创建两张表分别是：userinfo 和 userdetail。接下来看看 Go 官方提供的示例代码：
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
//"time"
)
func main() {
db, err := sql.Open("mysql", "root:123456@/test?charset=utf8")
checkErr(err)
//插入数据
stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
checkErr(err)
res, err := stmt.Exec("astaxie", "WeChat", "2012-12-09")
checkErr(err)
id, err := res.LastInsertId()
checkErr(err)
fmt.Println(id)
//更新数据
stmt, err = db.Prepare("update userinfo set username=? where uid=?")
checkErr(err)
res, err = stmt.Exec("astaxieupdate", id)
checkErr(err)
affect, err := res.RowsAffected()
checkErr(err)
fmt.Println(affect)
//查询数据
rows, err := db.Query("SELECT * FROM userinfo")
checkErr(err)
for rows.Next() {
var uid int
var username string
var department string
var created string
err = rows.Scan(&uid, &username, &department, &created)
checkErr(err)
fmt.Println(uid)
fmt.Println(username)
fmt.Println(department)
fmt.Println(created)
}
//删除数据
stmt, err = db.Prepare("delete from userinfo where uid=?")
checkErr(err)
res, err = stmt.Exec(id)
checkErr(err)
affect, err = res.RowsAffected()
checkErr(err)
fmt.Println(affect)
db.Close()
}
// 存在 error 进行 painc
func checkErr(err error) {
if err != nil {
panic(err)
}
}
输出结果如下所示：
[ `go run mysql_demo.go` | done: 345.222169ms ]
1
1
1
astaxieupdate
WeChat
2012-12-09
1
### Beego 进行 ORM
ORM 是一种对象关系的映射。接下来体验一下 Beego 中内部支持的 ORM。我们还是先来安装 beego 框架。
go get github.com/astaxie/beego
package main
import (
"fmt"
"github.com/astaxie/beego/orm"
_ "github.com/go-sql-driver/mysql" // 导入数据库驱动
)
// Model Struct
type User struct {
Id int
Name string `orm:"size(100)"`
}
func init() {
// 设置默认数据库
orm.RegisterDataBase("default", "mysql", "root:root@/my_db?charset=utf8", 30)
// 注册定义的 model
orm.RegisterModel(new(User))
//RegisterModel 也可以同时注册多个 model
//orm.RegisterModel(new(User), new(Profile), new(Post))
// 创建 table
orm.RunSyncdb("default", false, true)
}
其中第二个 root是你的本地 Mysql 数据库密码，而 my_db 就是你的数据库名称。下面是一些常用的操作：
func main() {
o := orm.NewOrm()
// 基本的赋值
user := User{Name: "slene"}
// 插入表
id, err := o.Insert(&user)
fmt.Printf("ID: %d, ERR: %v\n", id, err)
// 更新表
user.Name = "astaxie"
num, err := o.Update(&user)
fmt.Printf("NUM: %d, ERR: %v\n", num, err)
// 读取 one
u := User{Id: user.Id}
err = o.Read(&u)
fmt.Printf("ERR: %v\n", err)
// 删除表
num, err = o.Delete(&u)
fmt.Printf("NUM: %d, ERR: %v\n", num, err)
}
如上可见，我们基本上没有直接对 Mysql 数据库进行操作，而是通过一个实体类型来对数据库某个表进行各种操作。
