Go語言操作數(shù)據(jù)庫非常的簡單,

創(chuàng)新互聯(lián)公司堅實的技術研發(fā)基礎贏得了行業(yè)內的良好口碑,公司成立10多年來,為數(shù)千家企業(yè)提供過網(wǎng)站建設、軟件開發(fā)、搜索引擎優(yōu)化技術、互聯(lián)網(wǎng)大數(shù)據(jù)整合營銷服務,多年的技術服務成功經(jīng)驗、眾多的客戶使我們能懂得更多,做得更好。"讓您的網(wǎng)站跑起來"是我們一直追求的目標!
他也有一個類似JDBC的東西"database/sql"
實現(xiàn)類是"github.com/go-sql-driver/mysql"
使用過JDBC的人應該一看就懂
對日期的處理比較晦澀,沒有JAVA流暢:
復制代碼代碼如下:
package main
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
"log"
"time"
)
/*
create table t(
id int primary key auto_increment,
name varchar(20) not null,
ts timestamp
);
*/
func insert(db *sql.DB) {
stmt, err := db.Prepare("insert into t(name,ts) values(?,?)")
defer stmt.Close()
if err != nil {
log.Println(err)
return
}
ts, _ := time.Parse("2006-01-02 15:04:05", "2014-08-28 15:04:00")
stmt.Exec("edmond", ts)
}
func main() {
db, err := sql.Open("mysql", "xx:xx@tcp(127.0.0.1:3306)/mvbox?charset=utf8")
if err != nil {
log.Fatalf("Open database error: %s\n", err)
}
defer db.Close()
err = db.Ping()
if err != nil {
log.Fatal(err)
}
在本節(jié)中,您將使用 Go 執(zhí)行 SQL INSERT語句以向數(shù)據(jù)庫添加新行。
您已經(jīng)了解了如何使用Query和QueryRow處理返回數(shù)據(jù)的 SQL 語句。要執(zhí)行 不 返回數(shù)據(jù)的 SQL 語句,請使用Exec.
1、在albumByID下面,粘貼以下addAlbum函數(shù)以在數(shù)據(jù)庫中插入新專輯,然后保存 main.go。
在此代碼中:
(1)用DB.Exec執(zhí)行INSERT語句。
Exec接受一條 SQL 語句,后跟 SQL 語句的參數(shù)值。
(2)檢查嘗試INSERT中的錯誤。
(3)使用Result.LastInsertId檢索插入的數(shù)據(jù)庫行的 ID 。
(4)檢查嘗試檢索 ID 的錯誤。
2、更新main以調用新addAlbum函數(shù)。
在main函數(shù)末尾添加以下代碼。
在新代碼中:
(1)調用addAlbum添加新專輯,將要添加的專輯的 ID 分配給albID變量。
從包含 main.go 目錄的命令行中,運行代碼。
恭喜!您剛剛使用 Go 對關系數(shù)據(jù)庫執(zhí)行了簡單的操作。
本節(jié)包含您使用本教程構建的應用程序的代碼。
insert into #ForMonth exec(@Sql)使用這樣的SQL語句,首先是表#ForMonth必須存在,如果不存在這個表,要用select * into #ForMonth from 表名
你可以這樣寫試一下(只后面幾句,前面的不變)
SET @Sql='select * into #ForMonth from #TotalSalesForMonth pivot (sum(total) for monthN in ('+@str+') ) as pvt '
drop table #ForMonth --刪除臨時表exec(@Sql)
Golang的interface,和別的語言是不同的。它不需要顯式的implements,只要某個struct實現(xiàn)了interface里的所有函數(shù),編譯器會自動認為它實現(xiàn)了這個interface。
SICP里詳細解釋了為什么同一個接口,需要根據(jù)不同的數(shù)據(jù)類型,有不同的實現(xiàn);以及如何做到這一點。在這里沒有OO的概念,先把OO放到一邊,從原理上看一下這是怎么做到的。
先把大概原理放在這里,然后再舉例子。為了實現(xiàn)多態(tài),需要維護一張全局的查找表,它的功能是根據(jù)類型名和方法名,返回對應的函數(shù)入口。當我增加了一種類型,需要把新類型的名字、相應的方法名和實際函數(shù)入口添加到表里。這基本上就是所謂的動態(tài)綁定了,類似于C++里的vtable。對于SICP中使用的lisp語言來說,這些工作需要手動完成。而對于java,則通過implements完成了這項工作。而golang則用了更加激進的方式,連implements都省了,編譯器自動發(fā)現(xiàn)自動綁定。
有很多教程是關于Go的sql.DB類型和如何使用它來執(zhí)行SQL數(shù)據(jù)庫查詢的。但大多數(shù)內容都沒有講述 SetMaxOpenConns() , SetMaxIdleConns() 和 SetConnMaxLifetime()方法, 您可以使用它們來配置sql.DB的行為并改變其性能。
轉自:
整理:go語言中文文檔:
在本文我將詳細解釋這些設置的作用,并說明它們所能產(chǎn)生的(積極和消極)影響。
一個sql.DB對象就是一個數(shù)據(jù)庫連接池,它包含“正在用”和“空閑的”連接。一個正在用的連接指的是,你正用它來執(zhí)行數(shù)據(jù)庫任務,例如執(zhí)行SQL語句或行查詢。當任務完成連接就是空閑的。
當您創(chuàng)建sql.DB執(zhí)行數(shù)據(jù)庫任務時,它將首先檢查連接池中是否有可用的空閑連接。如果有可用的連接,那么Go將重用現(xiàn)有連接,并在執(zhí)行任務期間將其標記為正在使用。如果池中沒有空閑連接,而您需要一個空閑連接,那么Go將創(chuàng)建一個新的連接。
默認情況下,在同一時間打開連接的數(shù)量是沒有限制(包含使用中+空閑)。但你可以通過SetMaxOpenConns()方法實現(xiàn)自定義限制,如下所示:
在這個示例代碼中,連接池現(xiàn)在有5個并發(fā)打開的連接數(shù)。如果所有5個連接都已經(jīng)被標記為正在使用,并且需要另一個新的連接,那么應用程序將被迫等待,直到5個連接中的一個被釋放并變?yōu)榭臻e。
為了說明更改MaxOpenConns的影響,我運行了一個基準測試,將最大打開連接數(shù)設置為1、2、5、10和無限。基準測試在PostgreSQL數(shù)據(jù)庫上執(zhí)行并行的INSERT語句,您可以在這里找到代碼。測試結果:
對于這個基準測試,我們可以看到,允許打開的連接越多,在數(shù)據(jù)庫上執(zhí)行INSERT操作所花費的時間就越少(打開的連接數(shù)為1時,執(zhí)行速度3129633ns/op,而無限連接:531030ns/op——大約快了6倍)。這是因為允許打開的連接越多,可以并發(fā)執(zhí)行的數(shù)據(jù)庫查詢就越多。
默認情況下,sql.DB允許連接池中最多保留2個空閑連接。你可以通過SetMaxIdleConns()方法改變它,如下所示:
從理論上講,允許池中有更多的空閑連接將提高性能,因為這樣就不太可能從頭開始建立新連接——因此有助于提升數(shù)據(jù)庫性能。
讓我們來看看相同的基準測試,最大空閑連接設置為none, 1,2,5和10:
當MaxIdleConns設置為none時,必須為每個INSERT從頭創(chuàng)建一個新的連接,我們可以從基準測試中看到,平均運行時和內存使用量相對較高。
只允許保留和重用一個空閑連接對基準測試影響特別明顯——它將平均運行時間減少了大約8倍,內存使用量減少了大約20倍。繼續(xù)增加空閑連接池的大小會使性能變得更好,盡管改進并不明顯。
那么,您應該維護一個大的空閑連接池嗎?答案取決于應用程序。重要的是要意識到保持空閑連接是有代價的—它占用了可以用于應用程序和數(shù)據(jù)庫的內存。
還有一種可能是,如果一個連接空閑時間太長,那么它可能會變得不可用。例如,MySQL的wait_timeout設置將自動關閉任何8小時(默認)內未使用的連接。
當發(fā)生這種情況時,sql.DB會優(yōu)雅地處理它。壞連接將自動重試兩次,然后放棄,此時Go將該連接從連接池中刪除,并創(chuàng)建一個新的連接。因此,將MaxIdleConns設置得太大可能會導致連接變得不可用,與空閑連接池更小(使用更頻繁的連接更少)相比,會占有更多的資源。所以,如果你很可能很快就會再次使用,你只需保持一個空閑的連接。
最后要指出的是,MaxIdleConns應該總是小于或等于MaxOpenConns。Go強制執(zhí)行此操作,并在必要時自動減少MaxIdleConns。
現(xiàn)在讓我們看看SetConnMaxLifetime()方法,它設置連接可重用的最大時間長度。如果您的SQL數(shù)據(jù)庫也實現(xiàn)了最大連接生命周期,或者—例如—您希望方便地在負載均衡器后交換數(shù)據(jù)庫,那么這將非常有用。
你可以這樣使用它:
在這個例子中,所有的連接都將在創(chuàng)建后1小時“過期”,并且在過期后無法重用。但注意:
從理論上講,ConnMaxLifetime越短,連接過期的頻率就越高——因此,需要從頭創(chuàng)建連接的頻率就越高。為了說明這一點,我運行了將ConnMaxLifetime設置為100ms、200ms、500ms、1000ms和無限(永遠重用)的基準測試,默認設置為無限打開連接和2個空閑連接。這些時間段顯然比您在大多數(shù)應用程序中使用的時間要短得多,但它們有助于很好地說明行為。
在這些特定的基準測試中,我們可以看到,與無限生存期相比,在100ms生存期時內存使用量增加了3倍以上,而且每個INSERT的平均運行時也稍微長一些。
如果您在代碼中設置了ConnMaxLifetime,那么一定要記住連接將過期(隨后重新創(chuàng)建)的頻率。例如,如果您總共有100個連接,而ConnMaxLifetime為1分鐘,那么您的應用程序可能每秒鐘殺死和重新創(chuàng)建1.67個連接(平均值)。您不希望這個頻率太大,最終會阻礙性能,而不是提高性能。
最后,如果不說明超過數(shù)據(jù)庫連接數(shù)量的硬限制將會發(fā)生什么,那么本文就不完整了。 為了說明這一點,我將修改postgresql.conf文件,這樣總共只允許5個連接(默認是100個)…
然后在無限連接的情況下重新運行基準測試……
一旦達到5個連接的硬限制,數(shù)據(jù)庫驅動程序(pq)立即返回一個太多客戶端連接的錯誤消息,而無法完成INSERT。為了防止這個錯誤,我們需要將sql.DB中打開連接的最大總數(shù)(正在使用的+空閑的)設置為低于5。像這樣:
現(xiàn)在,sql.DB在任何時候最多只能創(chuàng)建3個連接,基準測試運行時應該不會出現(xiàn)任何錯誤。但是這樣做需要注意:當達到開放連接數(shù)限制,并且所有連接都在使用時,應用程序需要執(zhí)行的任何新的數(shù)據(jù)庫任務都將被迫等待,直到連接標記為空閑。例如,在web應用程序的上下文中,用戶的HTTP請求看起來會“掛起”,甚至在等待數(shù)據(jù)庫任務運行時可能會超時。
為了減輕這種情況,你應該始終在一個上下文中傳遞。在調用數(shù)據(jù)庫時,啟用上下文的方法(如ExecContext()),使用固定的、快速的超時上下文對象。
總結
1、根據(jù)經(jīng)驗,應該顯式設置MaxOpenConns值。這應該小于數(shù)據(jù)庫和基礎設施對連接數(shù)量的硬性限制。
2、一般來說,更高的MaxOpenConns和MaxIdleConns值將帶來更好的性能。但你應該注意到效果是遞減的,連接池空閑連接太多(連接沒有被重用,最終會變壞)實際上會導致性能下降。
3、為了降低上面第2點帶來的風險,您可能需要設置一個相對較短的ConnMaxLifetime。但你也不希望它太短,導致連接被殺死或不必要地頻繁重建。
4、MaxIdleConns應該總是小于或等于MaxOpenConns。
對于中小型web應用程序,我通常使用以下設置作為起點,然后根據(jù)實際吞吐量水平的負載測試結果進行優(yōu)化。
分享文章:go語言中insert,Go語言中的Handle
分享地址:http://chinadenli.net/article45/dsihchi.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供外貿網(wǎng)站建設、手機網(wǎng)站建設、網(wǎng)站收錄、品牌網(wǎng)站制作、ChatGPT、App設計
聲明:本網(wǎng)站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經(jīng)允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)