Golang database/sql源碼分析

Gorm是Go語言開發(fā)用的比較多的一個(gè)ORM。它的功能比較全：

創(chuàng)新互聯(lián)建站專注于企業(yè)成都全網(wǎng)營銷推廣、網(wǎng)站重做改版、陽西網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5高端網(wǎng)站建設(shè)、成都商城網(wǎng)站開發(fā)、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)網(wǎng)站制作、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為陽西等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。

但是這篇文章中并不會(huì)直接看Gorm的源碼，我們會(huì)先從database/sql分析。原因是Gorm也是基于這個(gè)包來封裝的一些功能。所以只有先了解了database/sql包才能更加好的理解Gorm源碼。

database/sql 其實(shí)也是一個(gè)對于mysql驅(qū)動(dòng)的上層封裝。”github.com/go-sql-driver/mysql”就是一個(gè)對于mysql的驅(qū)動(dòng)，database/sql 就是在這個(gè)基礎(chǔ)上做的基本封裝包含連接池的使用

下面這個(gè)是最基本的增刪改查操作

操作分下面幾個(gè)步驟：

因?yàn)镚orm的連接池就是使用database/sql包中的連接池，所以這里我們需要學(xué)習(xí)一下包里的連接池的源碼實(shí)現(xiàn)。其實(shí)所有連接池最重要的就是連接池對象、獲取函數(shù)、釋放函數(shù)下面來看一下database/sql中的連接池。

DB對象

獲取方法

釋放連接方法

連接池的實(shí)現(xiàn)有很多方法，在database/sql包中使用的是chan阻塞 使用map記錄等待列表，等到有連接釋放的時(shí)候再把連接傳入等待列表中的chan 不在阻塞返回連接。

之前我們看到的Redigo是使用一個(gè)chan 來阻塞，然后釋放的時(shí)候放入空閑列表，在往這一個(gè)chan中傳入struct{}{}，讓程序繼續(xù) 獲取的時(shí)候再從空閑列表中獲取。并且使用的是鏈表的結(jié)構(gòu)來存儲(chǔ)空閑列表。

database/sql 是對于mysql驅(qū)動(dòng)的封裝，然而Gorm則是對于database/sql的再次封裝。讓我們可以更加簡單的實(shí)現(xiàn)對于mysql數(shù)據(jù)庫的操作。

golang能否監(jiān)聽Mysql數(shù)據(jù)庫的表是否有增刪改操作

defer rows.Close()

var id int //定義一個(gè)id 變量

var lvs string //定義lvs 變量

for rows.Next() { //開始循環(huán)

rerr := rows.Scan(id, lvs) //數(shù)據(jù)指針，會(huì)把得到的數(shù)據(jù)，往剛才id 和 lvs引入

if rerr == nil {

fmt.Println("id號(hào)是",strconv.Itoa(id) + " lvs lvs是"+ lvs) //輸出來而已，看看

}

}

insert_sql := "INSERT INTO xiaorui(lvs) VALUES(?)"

_, e4 := db.Exec(insert_sql,"nima")

fmt.Println(e4)

db.Close() //關(guān)閉數(shù)據(jù)庫

}

GO語言（三十）：訪問關(guān)系型數(shù)據(jù)庫（上）

本教程介紹了使用 Godatabase/sql及其標(biāo)準(zhǔn)庫中的包訪問關(guān)系數(shù)據(jù)庫的基礎(chǔ)知識(shí)。

您將使用的database/sql包包括用于連接數(shù)據(jù)庫、執(zhí)行事務(wù)、取消正在進(jìn)行的操作等的類型和函數(shù)。

在本教程中，您將創(chuàng)建一個(gè)數(shù)據(jù)庫，然后編寫代碼來訪問該數(shù)據(jù)庫。您的示例項(xiàng)目將是有關(guān)老式爵士樂唱片的數(shù)據(jù)存儲(chǔ)庫。

首先，為您要編寫的代碼創(chuàng)建一個(gè)文件夾。

1、打開命令提示符并切換到您的主目錄。

在 Linux 或 Mac 上：

在 Windows 上：

2、在命令提示符下，為您的代碼創(chuàng)建一個(gè)名為 data-access 的目錄。

3、創(chuàng)建一個(gè)模塊，您可以在其中管理將在本教程中添加的依賴項(xiàng)。

運(yùn)行g(shù)o mod init命令，為其提供新代碼的模塊路徑。

此命令創(chuàng)建一個(gè) go.mod 文件，您添加的依賴項(xiàng)將在其中列出以供跟蹤。

注意： 在實(shí)際開發(fā)中，您會(huì)指定一個(gè)更符合您自己需求的模塊路徑。有關(guān)更多信息，請參閱一下文章。

GO語言（二十五）：管理依賴項(xiàng)（上）

GO語言（二十六）：管理依賴項(xiàng)（中）

GO語言（二十七）：管理依賴項(xiàng)（下）

接下來，您將創(chuàng)建一個(gè)數(shù)據(jù)庫。

在此步驟中，您將創(chuàng)建要使用的數(shù)據(jù)庫。您將使用 DBMS 本身的 CLI 創(chuàng)建數(shù)據(jù)庫和表，以及添加數(shù)據(jù)。

您將創(chuàng)建一個(gè)數(shù)據(jù)庫，其中包含有關(guān)黑膠唱片上的老式爵士樂錄音的數(shù)據(jù)。

這里的代碼使用MySQL CLI，但大多數(shù) DBMS 都有自己的 CLI，具有類似的功能。

1、打開一個(gè)新的命令提示符。

在命令行，登錄到您的 DBMS，如下面的 MySQL 示例所示。

2、在mysql命令提示符下，創(chuàng)建一個(gè)數(shù)據(jù)庫。

3、切到您剛剛創(chuàng)建的數(shù)據(jù)庫，以便您可以添加表。

4、在文本編輯器的 data-access 文件夾中，創(chuàng)建一個(gè)名為 create-tables.sql 的文件來保存用于添加表的 SQL 腳本。

將以下 SQL 代碼粘貼到文件中，然后保存文件。

在此 SQL 代碼中：

（1）刪除名為album表。 首先執(zhí)行此命令可以讓您更輕松地稍后重新運(yùn)行腳本。

（2）創(chuàng)建一個(gè)album包含四列的表：title、artist和price。每行的id值由 DBMS 自動(dòng)創(chuàng)建。

（3）添加帶有值的四行。

5、在mysql命令提示符下，運(yùn)行您剛剛創(chuàng)建的腳本。

您將使用以下形式的source命令：

6、在 DBMS 命令提示符處，使用SELECT語句來驗(yàn)證您是否已成功創(chuàng)建包含數(shù)據(jù)的表。

接下來，您將編寫一些 Go 代碼進(jìn)行連接，以便進(jìn)行查詢。

現(xiàn)在你已經(jīng)有了一個(gè)包含一些數(shù)據(jù)的數(shù)據(jù)庫，開始你的 Go 代碼。

找到并導(dǎo)入一個(gè)數(shù)據(jù)庫驅(qū)動(dòng)程序，該驅(qū)動(dòng)程序會(huì)將您通過database/sql包中的函數(shù)發(fā)出的請求轉(zhuǎn)換為數(shù)據(jù)庫可以理解的請求。

1、在您的瀏覽器中，訪問SQLDrivers wiki 頁面以識(shí)別您可以使用的驅(qū)動(dòng)程序。

2、使用頁面上的列表來識(shí)別您將使用的驅(qū)動(dòng)程序。為了在本教程中訪問 MySQL，您將使用 Go-MySQL-Driver。

3、請注意驅(qū)動(dòng)程序的包名稱 - 此處為github.com/go-sql-driver/mysql.

4、使用您的文本編輯器，創(chuàng)建一個(gè)用于編寫 Go 代碼的文件，并將該文件作為 main.go 保存在您之前創(chuàng)建的數(shù)據(jù)訪問目錄中。

5、進(jìn)入main.go，粘貼以下代碼導(dǎo)入驅(qū)動(dòng)包。

在此代碼中：

（1）將您的代碼添加到main包中，以便您可以獨(dú)立執(zhí)行它。

（2）導(dǎo)入 MySQL 驅(qū)動(dòng)程序github.com/go-sql-driver/mysql。

導(dǎo)入驅(qū)動(dòng)程序后，您將開始編寫代碼以訪問數(shù)據(jù)庫。

現(xiàn)在編寫一些 Go 代碼，讓您使用數(shù)據(jù)庫句柄訪問數(shù)據(jù)庫。

您將使用指向結(jié)構(gòu)的指針sql.DB，它表示對特定數(shù)據(jù)庫的訪問。

編寫代碼

1、進(jìn)入 main.go，在import您剛剛添加的代碼下方，粘貼以下 Go 代碼以創(chuàng)建數(shù)據(jù)庫句柄。

在此代碼中：

（3）使用 MySQL 驅(qū)動(dòng)程序Config和FormatDSN類型以收集連接屬性并將它們格式化為連接字符串的 DSN。

該Config結(jié)構(gòu)使代碼比連接字符串更容易閱讀。

（4）調(diào)用sql.Open 初始化db變量，傳遞 FormatDSN。

（5）檢查來自 的錯(cuò)誤sql.Open。例如，如果您的數(shù)據(jù)庫連接細(xì)節(jié)格式不正確，它可能會(huì)失敗。

為了簡化代碼，您調(diào)用log.Fatal結(jié)束執(zhí)行并將錯(cuò)誤打印到控制臺(tái)。在生產(chǎn)代碼中，您會(huì)希望以更優(yōu)雅的方式處理錯(cuò)誤。

（6）調(diào)用DB.Ping以確認(rèn)連接到數(shù)據(jù)庫有效。在運(yùn)行時(shí)， sql.Open可能不會(huì)立即連接，具體取決于驅(qū)動(dòng)程序。您在Ping此處使用以確認(rèn) database/sql包可以在需要時(shí)連接。

（7）檢查來自Ping的錯(cuò)誤，以防連接失敗。

（8）Ping如果連接成功，則打印一條消息。

文件的頂部現(xiàn)在應(yīng)該如下所示：

3、保存 main.go。

1、開始跟蹤 MySQL 驅(qū)動(dòng)程序模塊作為依賴項(xiàng)。

使用go get 添加 github.com/go-sql-driver/mysql 模塊作為您自己模塊的依賴項(xiàng)。使用點(diǎn)參數(shù)表示“獲取當(dāng)前目錄中代碼的依賴項(xiàng)”。

2、在命令提示符下，設(shè)置Go 程序使用的DBUSER和DBPASS環(huán)境變量。

在 Linux 或 Mac 上：

在 Windows 上：

3、在包含 main.go 的目錄中的命令行中，通過鍵入go run來運(yùn)行代碼。

連接成功了！

接下來，您將查詢一些數(shù)據(jù)。

數(shù)據(jù)庫中增刪改查的基本語句是什么？

數(shù)據(jù)庫中增刪改查基本語句：INSERT INTO，表名字段列表。

數(shù)據(jù)庫是存放數(shù)據(jù)的倉庫。它的存儲(chǔ)空間很大，可以存放百萬條、千萬條、上億條數(shù)據(jù)。但是數(shù)據(jù)庫并不是隨意地將數(shù)據(jù)進(jìn)行存放，是有一定的規(guī)則的，否則查詢的效率會(huì)很低。

當(dāng)今世界是一個(gè)充滿著數(shù)據(jù)的互聯(lián)網(wǎng)世界，充斥著大量的數(shù)據(jù)。即這個(gè)互聯(lián)網(wǎng)世界就是數(shù)據(jù)世界。數(shù)據(jù)的來源有很多，比如出行記錄、消費(fèi)記錄、瀏覽的網(wǎng)頁、發(fā)送的消息等等。除了文本類型的數(shù)據(jù)，圖像、音樂、聲音都是數(shù)據(jù)。

在數(shù)據(jù)庫的發(fā)展歷史上，數(shù)據(jù)庫先后經(jīng)歷了層次數(shù)據(jù)庫、網(wǎng)狀數(shù)據(jù)庫和關(guān)系數(shù)據(jù)庫等各個(gè)階段的發(fā)展，數(shù)據(jù)庫技術(shù)在各個(gè)方面的快速的發(fā)展。特別是關(guān)系型數(shù)據(jù)庫已經(jīng)成為目前數(shù)據(jù)庫產(chǎn)品中最重要的一員。

80年代以來，幾乎所有的數(shù)據(jù)庫廠商新出的數(shù)據(jù)庫產(chǎn)品都支持關(guān)系型數(shù)據(jù)庫，即使一些非關(guān)系數(shù)據(jù)庫產(chǎn)品也幾乎都有支持關(guān)系數(shù)據(jù)庫的接口。

這主要是傳統(tǒng)的關(guān)系型數(shù)據(jù)庫可以比較好的解決管理和存儲(chǔ)關(guān)系型數(shù)據(jù)的問題。隨著云計(jì)算的發(fā)展和大數(shù)據(jù)時(shí)代的到來，關(guān)系型數(shù)據(jù)庫越來越無法滿足需要，這主要是由于越來越多的半關(guān)系型和非關(guān)系型數(shù)據(jù)需要用數(shù)據(jù)庫進(jìn)行存儲(chǔ)管理。

go語言postgresql數(shù)據(jù)庫驅(qū)動(dòng)怎么用

PostgreSQL和MySQL比較，它更加龐大一點(diǎn)，因?yàn)樗怯脕硖娲鶲racle而設(shè)計(jì)的。所以在企業(yè)應(yīng)用中采用PostgreSQL是一個(gè)明智的選擇。

現(xiàn)在MySQL被Oracle收購之后，有傳聞Oracle正在逐步的封閉MySQL,,鑒于此，將來我們也許會(huì)選擇PostgreSQL而不是MySQL作為項(xiàng)目的后端數(shù)據(jù)庫。

1、驅(qū)動(dòng)

Go實(shí)現(xiàn)的支持PostgreSQL的驅(qū)動(dòng)也很多，因?yàn)閲夂芏嗳嗽陂_發(fā)中使用了這個(gè)數(shù)據(jù)庫。

支持database/sql驅(qū)動(dòng)，純Go寫的

支持database/sql驅(qū)動(dòng)，純Go寫的

支持database/sql驅(qū)動(dòng)，純Go寫的

在下面的示例中我采用了第一個(gè)驅(qū)動(dòng)，因?yàn)樗壳笆褂玫娜俗疃啵趃ithub上也比較活躍。

2、實(shí)例代碼

數(shù)據(jù)庫建表語句：

復(fù)制代碼

CREATE TABLE userinfo

(

uid serial NOT NULL,

username character varying(100) NOT NULL,

departname character varying(500) NOT NULL,

Created date,

CONSTRAINT userinfo_pkey PRIMARY KEY (uid)

)

WITH (OIDS=FALSE);

CREATE TABLE userdeatail

(

uid integer,

intro character varying(100),

profile character varying(100)

)

WITH(OIDS=FALSE);

復(fù)制代碼

看下面這個(gè)Go如何操作數(shù)據(jù)庫表數(shù)據(jù):增刪改查

復(fù)制代碼

package main

import (

"database/sql"

"fmt"

_ "github.com/bmizerany/pq"

)

func main() {

db, err := sql.Open("postgres", "user=astaxie password=astaxie dbname=test sslmode=disable")

checkErr(err)

//插入數(shù)據(jù)

stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")

checkErr(err)

res, err := stmt.Exec("astaxie", "研發(fā)部門", "2012-12-09")

checkErr(err)

//pg不支持這個(gè)函數(shù)，因?yàn)樗麤]有類似MySQL的自增ID

id, err := res.LastInsertId()

checkErr(err)

fmt.Println(id)

//更新數(shù)據(jù)

stmt, err = db.Prepare("update userinfo set username=$1 where uid=$2")

checkErr(err)

res, err = stmt.Exec("astaxieupdate", 1)

checkErr(err)

affect, err := res.RowsAffected()

checkErr(err)

fmt.Println(affect)

//查詢數(shù)據(jù)

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)

}

//刪除數(shù)據(jù)

stmt, err = db.Prepare("delete from userinfo where uid=$1")

checkErr(err)

res, err = stmt.Exec(1)

checkErr(err)

affect, err = res.RowsAffected()

checkErr(err)

fmt.Println(affect)

db.Close()

}

func checkErr(err error) {

if err != nil {

panic(err)

}

}

復(fù)制代碼

從上面的代碼我們可以看到，PostgreSQL是通過$1,$2這種方式來指定要傳遞的參數(shù)，而不是MySQL中的?，另外在sql.Open中的dsn信息的格式也與MySQL的驅(qū)動(dòng)中的dsn格式不一樣，所以在使用時(shí)請注意它們的差異。

還有pg不支持LastInsertId函數(shù)，因?yàn)镻ostgreSQL內(nèi)部沒有實(shí)現(xiàn)類似MySQL的自增ID返回，其他的代碼幾乎是一模一樣

golang 的數(shù)據(jù)庫操作感覺不怎么好，哎，PHP 直接 mysql

用的這個(gè) github.com/go-sql-driver/mysql 我用 select * from tablename,查詢出來， Scan 函數(shù)呢，還需要自己定義所查詢的變量，然后存儲(chǔ)結(jié)果集，另外一種方法，還需要自己定義中轉(zhuǎn)?

//循環(huán)輸出結(jié)果集?

//for rows.Next() {?

// var id int?

// var username string?

// err = rows.Scan(id, username) //Scan 此函數(shù)真的很不爽?

// checkErr(err)?

// fmt.Println(id)?

// fmt.Println(username)?

//?推薦你去后盾人上面看看里面有很多關(guān)于這類php之類的教學(xué)講解視頻，你可以去學(xué)學(xué)看

網(wǎng)頁標(biāo)題：go語言數(shù)據(jù)庫增刪改查,golang 增刪改查
本文URL：http://vcdvsql.cn/article34/heoppe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)網(wǎng)站建設(shè)、域名注冊、小程序開發(fā)、ChatGPT、網(wǎng)站維護(hù)、網(wǎng)站設(shè)計(jì)公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)