#まえがき
APIを作るにあたって大規模の同時接続に対応させたいと考え，
PythonのDjangoで作成していたAPIをGolangで作成し直すことにした。
なかなか思い通りに動かせず，つまづいた点が多くあったので記録に残す。
#Goの環境設定
// 確認
% go version
go version go1.16.2 darwin/amd64
// 環境情報
% go env
GO111MODULE=""
GOARCH="amd64"
GOBIN=""
GOCACHE="/Users/akidon/Library/Caches/go-build"
GOENV="/Users/akidon/Library/Application Support/go/env"
GOEXE=""
GOFLAGS=""
GOHOSTARCH="amd64"
GOHOSTOS="darwin"
GOINSECURE=""
GOMODCACHE="/Users/akidon/go/pkg/mod"
GONOPROXY=""
GONOSUMDB=""
GOOS="darwin"
GOPATH="/Users/akidon/go"
GOPRIVATE=""
GOPROXY="https://proxy.golang.org,direct"
GOROOT="/usr/local/go"
GOSUMDB="sum.golang.org"
GOTMPDIR=""
GOTOOLDIR="/usr/local/go/pkg/tool/darwin_amd64"
GOVCS=""
GOVERSION="go1.16.2"
GCCGO="gccgo"
AR="ar"
CC="clang"
CXX="clang++"
CGO_ENABLED="1"
GOMOD="/Users/akidon/program/go/goAPI/go.mod"
CGO_CFLAGS="-g -O2"
CGO_CPPFLAGS=""
CGO_CXXFLAGS="-g -O2"
CGO_FFLAGS="-g -O2"
CGO_LDFLAGS="-g -O2"
PKG_CONFIG="pkg-config"
GOGCCFLAGS="-fPIC -arch x86_64 -m64 -pthread -fno-caret-diagnostics -Qunused-arguments -fmessage-length=0 -fdebug-prefix-map=/var/folders/qg/6f_bf3fx4qs2gxwzhbc_pks00000gn/T/go-build311814080=/tmp/go-build -gno-record-gcc-switches -fno-common"
// PATH追加
% open ~/.zshrc
以下を追加
a.zshrc
#Goのパス
export GOROOT=/usr/local/go
export GOPATH=$HOME/go
export PATH=$GOROOT/bin:$PATH
export PATH=$GOPATH/bin:$PATH
動作確認
適当なフォルダにhello.goというファイルを作成して、Visual Studio Codeで下記のように編集。
package main
import "fmt"
func main() {
fmt.Println("Hello!");
}
ターミナルで先ほどのフォルダに移動して、 go run hello.go コマンドを実行。「Hello!」と表示されれば成功。
% go run hello.go
Hello!
#Goのパッケージ
Echo ... RestfullAPIの作成(他にもGinやGorillaなどがある)
Gorm ... MySQLを操作するため
もし以下のエラーが出れば
cannot find package "github.com/hoge"
go get github.com/hoge すればよい
% go mod init go-tools
% go get github.com/labstack/echo
% go get github.com/jinzhu/gorm
% go get github.com/joho/godotenv
MySQLをダウンロード
Mac 初期設定 備忘録
からMySQLをダウンロード
% mysql.server start
// mysql.server stop でサーバー停止
# MySQLに入る
% mysql -u root
# アカウント作成
mysql> create user 'ユーザー名'@'localhost' identified by 'パスワード';
# データベース作成('golang'というDBを作成)
mysql> create database golang;
# 作成したアカウントに権限を追加
mysql> GRANT ALL ON golang.* TO 'ユーザー名'@'localhost';
mysql> exit;
SequelAceを使うとMySQLの操作が楽
SequelAceダウンロード
GolangからMySQLのデータを追加・更新・取得
##MySQL側
テーブル名 users
mysql> show databases;
+--------------------+
| Database |
+--------------------+
| golang | <- 作成
| information_schema |
| mysql |
| performance_schema |
| sys |
+--------------------+
mysql> use golang;
mysql> show tables;
+------------------+
| Tables_in_golang |
+------------------+
| users |
+------------------+
mysql> desc users;
+-------------+--------------+------+-----+---------+----------------+
| Field | Type | Null | Key | Default | Extra |
+-------------+--------------+------+-----+---------+----------------+
| id | int unsigned | NO | PRI | NULL | auto_increment |
| name | varchar(255) | YES | | NULL | |
| age | int | YES | | NULL | |
| created_at | timestamp | YES | | NULL | | <- 必要
| updated_at | timestamp | YES | | NULL | | <- 必要
| deleted_at | timestamp | YES | | NULL | | <- 必要
+-------------+--------------+------+-----+---------+----------------+
SequelAceを使ってこの様に作成した
Gormを使う際[created_at,updated_at,deleted_at]を作成しておく必要がある
##Golang側
gormを使用してMySQLを操作しようとしたが，つまずいた。
原因は詳しくは理解できていないが，命名が間違っていたっぽい。
大文字，小文字，複数，単数に注意して命名する必要があった。
MySQLではusersだが，Golangで呼び出すときは"User"
MySQLではnameだが，Golangで呼び出すときは"Name"
など注意が必要。
確認動作チャックはしていないのでエラーが出る可能性があります
main.go
package routing
import (
"fmt"
"github.com/labstack/echo"
"github.com/jinzhu/gorm"
_ "github.com/jinzhu/gorm/dialects/mysql"
)
type User struct {
gorm.Model
//`json:"--"`はリクエストボディに指定する名前
Name string `json:"name"`
Age int `json:"age"`
}
func (u User) String() string {
return fmt.Sprintf("Name:%s \n Age:%d \n ",
u.Name,
u.Age)
}
// ユーザーを登録，更新
func BaseAPI_user() echo.HandlerFunc {
return func(c echo.Context) error {
db := databases.GormConnect()
defer db.Close()
//リクエストボディ
user := new(User)
user1 := User{
Name: user.Name,
Age: user.Age,}
// 追加
insertUsers := []User{user1}
insert(insertUsers, db)
// 更新
update(user1, db)
// 検索（年齢一致）
var count = search(user.Age, db)
return c.JSON(200, count)
}
}
func insert(users []User, db *gorm.DB) {
for _, user := range users {
db.NewRecord(user)
db.Create(&user)
}
}
func update(users User, db *gorm.DB) {
var user User
db.Model(&user).Where("id = ?", 1).Update(map[string]interface{}{"name": users.Name, "Age": users.Age})
}
func search(age int, db *gorm.DB) ([]User) {
var user []User
db.Raw("SELECT * FROM users WHERE age = ? ", age).Scan(&user)
return user
}
// SQLConnect DB接続
func GormConnect() (database *gorm.DB) {
// パスワード等を.envファイルから読み取る
// program > go > .env
err := godotenv.Load(fmt.Sprintf("../%s.env", os.Getenv("GO_ENV")))
if err != nil {
panic(err.Error())
} else {
fmt.Println("env読み取り成功")
}
DBMS := "mysql" // MySQL
PROTOCOL := "tcp(localhost:3306)" // db:3306
DBNAME := "" // テーブル名
USER := "" // MySQLユーザー名
PASS := "" // パスワード
CONNECT := USER + ":" + PASS + "@" + PROTOCOL + "/" + DBNAME + "?charset=utf8&parseTime=true&loc=Asia%2FTokyo"
db, err := gorm.Open(DBMS, CONNECT)
if err != nil {
panic(err.Error())
} else {
fmt.Println("DB接続成功")
}
return db
}