Go資料庫查詢底層流程

一般寫法：

db,err := sql.
open
("mysql"
,"root:123456@tcp(127.0.0.1:3306)/husky?charset=utf8");
rows,err := db.
query
("select * from test");
for rows.
next()

1.建立db

在執行open()之前，在程式啟動之後，會先執行mysql驅動中的init()方法，去註冊驅動到go基礎包的驅動管理中。而且這個init()方法是在呼叫open()方法時才會提前載入。然後呼叫mysql驅動中的open方法。

// sql.open實際上是呼叫的這個open方法

func

open

(drivername, datasourcename string)(

*db,

error

)if driverctx, ok := driveri.

(driver.drivercontext)

; ok

return

opendb

(connector)

,nil

}return

opendb

(dsnconnector),

nil}

// 主要任務就是dsn的解析

func

(d mysqldriver)

openconnector

(dsn string

)(driver.connector,

error

)return

&connector

,nil

}所以go中的sql.open()方法實際上是不建立連線的，也不去做認證校驗，如果要想真正的驗證連線，可以執行db.ping()方法。該方法也是真正的去建立連線，但只不過傳送的ping的資料報，沒有執行實際的查詢語句。在使用完連線也會呼叫putconn()方法放回連線池。

2.執行查詢

實際上呼叫的時querycontext()方法，引數需要ctx，這個是幫助後續執行完查詢或連線異常時釋放連線用的。query即使sql語句，如果sql要寫成「select * from table where name = ?」，則args要新增引數。

func
(db *db)
querycontext
(ctx context.context, query string
, args ...
inte***ce)(
*rows,
error)}
if err == driver.errbadconn 
return rows, err
}

query方法實際包含兩部分，乙個是根據策略去生成或獲取連線，另乙個是執行真正的查詢。

func
(db *db)
query
(ctx context.context, query string
, args [
]inte***ce
, strategy connreusestrategy)
(*rows,
error
)return db.
querydc
(ctx,
nil, dc, dc.releaseconn, query, args)
}

querydc()是真正的執行查詢的方法，

func
(db *db)
querydc
(ctx, txctx context.context, dc *driverconn, releaseconn func
(error
), query string
, args [
]inte***ce)(
*rows,
error
)if ok 
// 執行真正查詢，實際會呼叫mysql驅動中的querycontext()方法，
// querycontext()方法中會真正的將sql和引數轉換成符合mysql協議的包與mysql互動，
// 完成最後的查詢，返回driver.rows型別的查詢結果
rowsi, err =
ctxdriverquery
(ctx, queryerctx, queryer, query, nvdargs)})
if err != driver.errskip 
// 下面是為了將dc的釋放依賴於rows，在rows遍歷完時執行close**或釋放連線
rows :=
&rows
rows.
initcontextclose
(ctx, txctx)
return rows,
nil}
}var si driver.stmt
var err error
withlock
(dc,
func()
)if err !=
nil ds :=
&driverstmt
// 利用driverstmt執行查詢
rowsi, err :=
rowsifromstatement
(ctx, dc.ci, ds, args...
)if err !=
nil// 下面是為了將dc的釋放依賴於rows，在rows遍歷完時執行close**或釋放連線
rows :=
&rows
rows.
initcontextclose
(ctx, txctx)
return rows,
nil}

這裡注意rows.initcontextclose()方法，是等待rows的next()方法遍歷完成才會close掉這個rows，進而**或釋放連線，所以如果沒有遍歷完rows，連線是不會被收回的，再有其他請求需要獲取連線就會新建立連線，在新鏈結用完**時，會判斷當前連線數是否大於最大空閒連線數，如果大於就會被close掉，如果有大量請求觸發會造成效能問題。

Go資料庫查詢底層流程

Oracle資料庫底層

資料庫底層事務

資料庫設計流程

Go資料庫查詢底層流程

Oracle資料庫底層

資料庫底層 事務

資料庫設計流程

相關推薦

資料庫底層事務