站長資訊網(wǎng)
php入門到就業(yè)線上直播課：進(jìn)入學(xué)習(xí)
Apipost = Postman + Swagger + Mock + Jmeter 超好用的API調(diào)試工具：點(diǎn)擊使用
本教程操作環(huán)境：windows7系統(tǒng)、GO 1.18版本、Dell G3電腦。
golang支持多種數(shù)據(jù)庫
1、MySQL
MySQL是一款關(guān)系型數(shù)據(jù)庫管理系統(tǒng)，MySQL采用了雙授權(quán)政策，可以將數(shù)據(jù)保存在不同的表中，從而增加數(shù)據(jù)庫的速度和靈活性，具有體積小、速度快、總體擁有成本低的特點(diǎn)。
2、Oracle
oracle是一款關(guān)系數(shù)據(jù)庫管理系統(tǒng)，在數(shù)據(jù)庫領(lǐng)域處于領(lǐng)先地位，領(lǐng)先地位具有可移植性好、使用方便、功能強(qiáng)的特點(diǎn)，適用于各類大、中、小、微機(jī)環(huán)境，是一種效率高、可靠性好、吞吐量高的數(shù)據(jù)庫。
3、SQLite
SQLite是一款輕型數(shù)據(jù)庫，其遵循ACID關(guān)系型數(shù)據(jù)庫管理系統(tǒng)，其設(shè)計(jì)目的為嵌入式，所用可以在很多嵌入式產(chǎn)品中使用SQLite，同時(shí)可以和C#、PHP、Java等程序語言相結(jié)合使用。
4、MongoDB
MongoDB是一個(gè)基于分布式文件存儲(chǔ)的數(shù)據(jù)庫，其目的是為WEB應(yīng)用提供可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)方案，MongoDB支持的數(shù)據(jù)結(jié)構(gòu)非常松散，且支持多查詢語言和建立索引。
5、PostgreSQL
PostgreSQL是一個(gè)功能強(qiáng)大、源代碼開放的對(duì)象關(guān)系型數(shù)據(jù)庫管理系統(tǒng)，具有復(fù)雜查詢、外鍵、觸發(fā)器、視圖、事務(wù)完整性、多版本并發(fā)控制等特性，PostgreSQL可以通過函數(shù)在數(shù)據(jù)庫服務(wù)器端執(zhí)行指令程序，且用戶可以自定義索引方法。
6、SQL Sever
SQL Sever是一個(gè)關(guān)系型數(shù)據(jù)庫管理系統(tǒng)，具有使用方便、可伸縮性好、相關(guān)軟件集成程度高的優(yōu)點(diǎn)，可以提供更安全可靠的存儲(chǔ)性能，使用SQL Sever可以構(gòu)建和管理用于業(yè)務(wù)的高可用和高性能的數(shù)據(jù)應(yīng)用程序。
golang操作MySQL數(shù)據(jù)庫
下面主要從增刪查改以及事物等方面介紹go語言中mysql的使用
一、連接數(shù)據(jù)庫
使用sql.Open()函數(shù)打開數(shù)據(jù)庫連接，數(shù)據(jù)庫的連接字符串（dsn）格式如下：
admin:123456@tcp(10.2.1.5)/irisapp
代碼如下：
func (f *mysql_db) mysql_open() { db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname) if err != nil { fmt.Println("鏈接失敗") } fmt.Println("鏈接成功") f.db = db }
二、插入
func (f *mysql_db) mysql_insert() { //insert 添加數(shù)據(jù) fmt.Println("開始插入") stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)") //defer stmt.Close() if err != nil { fmt.Println("插入失敗") return } stmt.Exec("dd", "adadcccda") fmt.Println("插入成功") }
三、查詢
func (f *mysql_db) mysql_select(sql_data string) { //select 查詢數(shù)據(jù) fmt.Println("sql:", sql_data) rows, err := f.db.Query(sql_data) if err != nil { fmt.Println("查詢失敗") } for rows.Next() { var departID int var departName string var memo string err = rows.Scan(&departID, &departName, &memo) if err != nil { panic(err) } fmt.Println("departName:", departName) } }
四、更新
func (f *mysql_db) mysql_update() { //update 修改數(shù)據(jù) stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?") //defer stmt.Close() if err != nil { //錯(cuò)誤處理 } result,_ := stmt.Exec("aa","asdfadsadsfa",1) if result == nil { fmt.Println("修改失敗") } affect_count,_ := result.RowsAffected() //返回影響的條數(shù),注意有兩個(gè)返回值 fmt.Println("%v",affect_count) }
五、刪除
func (f *mysql_db) mysql_delete() { //delete 刪除數(shù)據(jù) stmt, err := f.db.Prepare("delete from depart where departId=?") //defer stmt.Close() if err != nil { //錯(cuò)誤處理 } stmt.Exec(2) //不返回任何結(jié)果 fmt.Println("刪除成功") }
六、事物
func (f *mysql_db) mysql_tran(){ //事務(wù) tx,err := f.db.Begin() //聲明一個(gè)事務(wù)的開始 if err != nil { fmt.Println(err) return } insert_sql := "insert into depart (departName,memo) VALUES(?,?)" insert_stmt,insert_err := tx.Prepare(insert_sql) if insert_err != nil { fmt.Println(insert_err) return } insert_res,insert_err := insert_stmt.Exec("ff","ff") last_insert_id,_ := insert_res.LastInsertId() fmt.Println(last_insert_id) // defer tx.Rollback() //回滾之前上面的last_login_id是有的，但在回滾后該操作沒有被提交，被回滾了，所以上面打印的Last_login_id的這條數(shù)據(jù)是不存在與數(shù)據(jù)庫表中的 tx.Commit() //這里提交了上面的操作，所以上面的執(zhí)行的sql 會(huì)在數(shù)據(jù)庫中產(chǎn)生一條數(shù)據(jù) }
調(diào)用
func main() { db := &mysql_db{} db.mysql_open() db.mysql_insert() db.mysql_update() db.mysql_delete() db.mysql_tran() db.mysql_select("select departID,departName,memo from depart") db.mysql_close() //關(guān)閉 }
啟動(dòng)后輸出如下：
D:Go_Pathgosrcmysqldemo>go run mysqldemo.go 鏈接成功 開始插入 插入成功 0 刪除成功 10 sql: select departID,departName,memo from depart departName: aa departName: dd departName: dd departName: dd departName: dd departName: dd departName: ff departName: dd departName: ff
完整代碼
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" ) var ( dbhostsip = "10.2.1.5:3306" dbusername = "admin" dbpassword = "123456" dbname = "irisapp" ) type mysql_db struct { db *sql.DB } func (f *mysql_db) mysql_open() { db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname) if err != nil { fmt.Println("鏈接失敗") } fmt.Println("鏈接成功") f.db = db } func (f *mysql_db) mysql_close() { defer f.db.Close() } func (f *mysql_db) mysql_select(sql_data string) { //select 查詢數(shù)據(jù) fmt.Println("sql:", sql_data) rows, err := f.db.Query(sql_data) if err != nil { fmt.Println("查詢失敗") } for rows.Next() { var departID int var departName string var memo string err = rows.Scan(&departID, &departName, &memo) if err != nil { panic(err) } fmt.Println("departName:", departName) } } func (f *mysql_db) mysql_insert() { //insert 添加數(shù)據(jù) fmt.Println("開始插入") stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)") //defer stmt.Close() if err != nil { fmt.Println("插入失敗") return } stmt.Exec("dd", "adadcccda") fmt.Println("插入成功") } func (f *mysql_db) mysql_update() { //update 修改數(shù)據(jù) stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?") //defer stmt.Close() if err != nil { //錯(cuò)誤處理 } result,_ := stmt.Exec("aa","asdfadsadsfa",1) if result == nil { fmt.Println("修改失敗") } affect_count,_ := result.RowsAffected() //返回影響的條數(shù),注意有兩個(gè)返回值 fmt.Println(affect_count) } func (f *mysql_db) mysql_delete() { //delete 刪除數(shù)據(jù) stmt, err := f.db.Prepare("delete from depart where departId=?") //defer stmt.Close() if err != nil { //錯(cuò)誤處理 } stmt.Exec(2) //不返回任何結(jié)果 fmt.Println("刪除成功") } func (f *mysql_db) mysql_tran(){ //事務(wù) tx,err := f.db.Begin() //聲明一個(gè)事務(wù)的開始 if err != nil { fmt.Println(err) return } insert_sql := "insert into depart (departName,memo) VALUES(?,?)" insert_stmt,insert_err := tx.Prepare(insert_sql) if insert_err != nil { fmt.Println(insert_err) return } insert_res,insert_err := insert_stmt.Exec("ff","ff") last_insert_id,_ := insert_res.LastInsertId() fmt.Println(last_insert_id) // defer tx.Rollback() //回滾之前上面的last_login_id是有的，但在回滾后該操作沒有被提交，被回滾了，所以上面打印的Last_login_id的這條數(shù)據(jù)是不存在與數(shù)據(jù)庫表中的 tx.Commit() //這里提交了上面的操作，所以上面的執(zhí)行的sql 會(huì)在數(shù)據(jù)庫中產(chǎn)生一條數(shù)據(jù) } func main() { db := &mysql_db{} db.mysql_open() db.mysql_insert() db.mysql_update() db.mysql_delete() db.mysql_tran() db.mysql_select("select departID,departName,memo from depart") db.mysql_close() //關(guān)閉 }
總結(jié)
1. 支持預(yù)備表達(dá)式，可以用來優(yōu)化SQL查詢提高性能，減少SQL注入的風(fēng)險(xiǎn), db.Prepare()和 tx.Prepare 都提供了對(duì)于預(yù)備表達(dá)式的支持。
2. LastInsertId() 獲取插入第一條的id
3. RowsAffected() 獲取影響/插入的條數(shù)
4. 這里只是簡單介紹了go語言開發(fā)中mysql在go語言開發(fā)中的基本使用，其實(shí)真正開發(fā)過程中還是主要使用orm相關(guān)第三方框架，但是底層原理還是要學(xué)的。
