站長資訊網
php入門到就業線上直播課：進入學習
Apipost = Postman + Swagger + Mock + Jmeter 超好用的API調試工具：點擊使用
本教程操作環境：windows7系統、GO 1.18版本、Dell G3電腦。
golang支持多種數據庫
1、MySQL
MySQL是一款關系型數據庫管理系統，MySQL采用了雙授權政策，可以將數據保存在不同的表中，從而增加數據庫的速度和靈活性，具有體積小、速度快、總體擁有成本低的特點。
2、Oracle
oracle是一款關系數據庫管理系統，在數據庫領域處于領先地位，領先地位具有可移植性好、使用方便、功能強的特點，適用于各類大、中、小、微機環境，是一種效率高、可靠性好、吞吐量高的數據庫。
3、SQLite
SQLite是一款輕型數據庫，其遵循ACID關系型數據庫管理系統，其設計目的為嵌入式，所用可以在很多嵌入式產品中使用SQLite，同時可以和C#、PHP、Java等程序語言相結合使用。
4、MongoDB
MongoDB是一個基于分布式文件存儲的數據庫，其目的是為WEB應用提供可擴展的高性能數據存儲方案，MongoDB支持的數據結構非常松散，且支持多查詢語言和建立索引。
5、PostgreSQL
PostgreSQL是一個功能強大、源代碼開放的對象關系型數據庫管理系統，具有復雜查詢、外鍵、觸發器、視圖、事務完整性、多版本并發控制等特性，PostgreSQL可以通過函數在數據庫服務器端執行指令程序，且用戶可以自定義索引方法。
6、SQL Sever
SQL Sever是一個關系型數據庫管理系統，具有使用方便、可伸縮性好、相關軟件集成程度高的優點，可以提供更安全可靠的存儲性能，使用SQL Sever可以構建和管理用于業務的高可用和高性能的數據應用程序。
golang操作MySQL數據庫
下面主要從增刪查改以及事物等方面介紹go語言中mysql的使用
一、連接數據庫
使用sql.Open()函數打開數據庫連接，數據庫的連接字符串（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 添加數據 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 查詢數據 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 修改數據 stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?") //defer stmt.Close() if err != nil { //錯誤處理 } result,_ := stmt.Exec("aa","asdfadsadsfa",1) if result == nil { fmt.Println("修改失敗") } affect_count,_ := result.RowsAffected() //返回影響的條數,注意有兩個返回值 fmt.Println("%v",affect_count) }
登錄后復制
五、刪除
func (f *mysql_db) mysql_delete() { //delete 刪除數據 stmt, err := f.db.Prepare("delete from depart where departId=?") //defer stmt.Close() if err != nil { //錯誤處理 } stmt.Exec(2) //不返回任何結果 fmt.Println("刪除成功") }
登錄后復制
六、事物
func (f *mysql_db) mysql_tran(){ //事務 tx,err := f.db.Begin() //聲明一個事務的開始 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的這條數據是不存在與數據庫表中的 tx.Commit() //這里提交了上面的操作，所以上面的執行的sql 會在數據庫中產生一條數據 }
登錄后復制
調用
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() //關閉 }
登錄后復制
啟動后輸出如下：
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 查詢數據 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 添加數據 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 修改數據 stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?") //defer stmt.Close() if err != nil { //錯誤處理 } result,_ := stmt.Exec("aa","asdfadsadsfa",1) if result == nil { fmt.Println("修改失敗") } affect_count,_ := result.RowsAffected() //返回影響的條數,注意有兩個返回值 fmt.Println(affect_count) } func (f *mysql_db) mysql_delete() { //delete 刪除數據 stmt, err := f.db.Prepare("delete from depart where departId=?") //defer stmt.Close() if err != nil { //錯誤處理 } stmt.Exec(2) //不返回任何結果 fmt.Println("刪除成功") } func (f *mysql_db) mysql_tran(){ //事務 tx,err := f.db.Begin() //聲明一個事務的開始 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的這條數據是不存在與數據庫表中的 tx.Commit() //這里提交了上面的操作，所以上面的執行的sql 會在數據庫中產生一條數據 } 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() //關閉 }
登錄后復制
總結
1. 支持預備表達式，可以用來優化SQL查詢提高性能，減少SQL注入的風險, db.Prepare()和 tx.Prepare 都提供了對于預備表達式的支持。
2. LastInsertId() 獲取插入第一條的id
3. RowsAffected() 獲取影響/插入的條數
4. 這里只是簡單介紹了go語言開發中mysql在go語言開發中的基本使用，其實真正開發過程中還是主要使用orm相關第三方框架，但是底層原理還是要學的。
