go語言中使用mysql sql語句

Go語言操作數據庫非常的簡單，

創新互聯專注于企業成都營銷網站建設、網站重做改版、內蒙古網站定制設計、自適應品牌網站建設、HTML5、商城網站制作、集團公司官網建設、成都外貿網站制作、高端網站制作、響應式網頁設計等建站業務，價格優惠性價比高，為內蒙古等各大城市提供網站開發制作服務。

他也有一個類似JDBC的東西"database/sql"

實現類是"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)

}

GoLang -- Gin框架

? 何為框架：

框架一直是敏捷開發中的利器，能讓開發者很快的上手并做出應用，甚至有的時候，脫離了框架，一些開發者都不會寫程序了。成長總不會一蹴而就，從寫出程序獲取成就感，再到精通框架，快速構造應用，當這些方面都得心應手的時候，可以嘗試改造一些框架，或是自己創造一個。

Gin是一個golang的微框架，封裝比較優雅，API友好，源碼注釋比較明確，已經發布了1.0版本。具有快速靈活，容錯方便等特點。其實對于golang而言，web框架的依賴要遠比Python，Java之類的要小。自身的net/http足夠簡單，性能也非常不錯。框架更像是一些常用函數或者工具的集合。借助框架開發，不僅可以省去很多常用的封裝帶來的時間，也有助于團隊的編碼風格和形成規范。

（1）首先需要安裝，安裝比較簡單，使用go get即可

go get github.com/gin-gonic/gin

如果安裝失敗，直接去Github clone下來，放置到對應的目錄即可。

（2）代碼中使用：

下面是一個使用Gin的簡單例子：

package main

import (

"github.com/gin-gonic/gin"

)

func main() {

router := gin.Default()

router.GET("/ping", func(c *gin.Context) {

c.JSON(200, gin.H{

"message": "pong",

})

})

router.Run(":8080") // listen and serve on 0.0.0.0:8080

}

簡單幾行代碼，就能實現一個web服務。使用gin的Default方法創建一個路由handler。然后通過HTTP方法綁定路由規則和路由函數。不同于net/http庫的路由函數，gin進行了封裝，把request和response都封裝到gin.Context的上下文環境。最后是啟動路由的Run方法監聽端口。麻雀雖小，五臟俱全。當然，除了GET方法，gin也支持POST,PUT,DELETE,OPTION等常用的restful方法。

Gin可以很方便的支持各種HTTP請求方法以及返回各種類型的數據，詳情可以前往查看。

2.1 匹配參數

我們可以使用Gin框架快速的匹配參數，如下代碼所示：

冒號:加上一個參數名組成路由參數。可以使用c.Param的方法讀取其值。當然這個值是字串string。諸如/user/rsj217，和/user/hello都可以匹配，而/user/和/user/rsj217/不會被匹配。

瀏覽器輸入以下測試：

返回結果為：

其中c.String是gin.Context下提供的方法，用來返回字符串。

其中c.Json是gin.Context下提供的方法，用來返回Json。

下面我們使用以下gin提供的Group函數，方便的為不同的API進行分類。

我們創建了一個gin的默認路由，并為其分配了一個組 v1，監聽hello請求并將其路由到視圖函數HelloPage，最后綁定到 0.0.0.0:8000

C.JSON是Gin實現的返回json數據的內置方法，包含了2個參數，狀態碼和返回的內容。http.StatusOK代表返回狀態碼為200，正文為{"message": “welcome"}。

注：Gin還包含更多的返回方法如c.String, c.HTML, c.XML等，請自行了解。可以方便的返回HTML數據

我們在之前的組v1路由下新定義一個路由：

下面我們訪問

可以看到，通過c.Param(“key”)方法，Gin成功捕獲了url請求路徑中的參數。同理，gin也可以捕獲常規參數，如下代碼所示：

在瀏覽器輸入以下代碼：

通過c.Query(“key”)可以成功接收到url參數，c.DefaultQuery在參數不存在的情況下，會由其默認值代替。

我們還可以為Gin定義一些默認路由：

這時候，我們訪問一個不存在的頁面：

返回如下所示：

下面我們測試在Gin里面使用Post

在測試端輸入：

附帶發送的數據，測試即可。記住需要使用POST方法.

繼續修改，將PostHandler的函數修改如下

測試工具輸入：

發送的內容輸入：

返回結果如下：

備注：此處需要指定Content-Type為application/x-www-form-urlencoded，否則識別不出來。

一定要選擇對應的PUT或者DELETE方法。

Gin框架快速的創建路由

能夠方便的創建分組

支持url正則表達式

支持參數查找（c.Param c.Query c.PostForm）

請求方法精準匹配

支持404處理

快速的返回給客戶端數據，常用的c.String c.JSON c.Data

如何在 Go 語言中使用 Redis 連接池

一、關于連接池

一個數據庫服務器只擁有有限的資源，并且如果你沒有充分使用這些資源，你可以通過使用更多的連接來提高吞吐量。一旦所有的資源都在使用，那么你就不 能通過增加更多的連接來提高吞吐量。事實上，吞吐量在連接負載較大時就開始下降了。通常可以通過限制與可用的資源相匹配的數據庫連接的數量來提高延遲和吞 吐量。

如何在Go語言中使用Redis連接池

如果不使用連接池，那么，每次傳輸數據，我們都需要進行創建連接，收發數據，關閉連接。在并發量不高的場景，基本上不會有什么問題，一旦并發量上去了，那么，一般就會遇到下面幾個常見問題：

性能普遍上不去

CPU 大量資源被系統消耗

網絡一旦抖動，會有大量 TIME_WAIT 產生，不得不定期重啟服務或定期重啟機器

服務器工作不穩定，QPS 忽高忽低

要想解決這些問題，我們就要用到連接池了。連接池的思路很簡單，在初始化時，創建一定數量的連接，先把所有長連接存起來，然后，誰需要使用，從這里取走，干完活立馬放回來。 如果請求數超出連接池容量，那么就排隊等待、退化成短連接或者直接丟棄掉。

二、使用連接池遇到的坑

最近在一個項目中，需要實現一個簡單的 Web Server 提供 Redis 的 HTTP interface，提供 JSON 形式的返回結果。考慮用 Go 來實現。

首先，去看一下 Redis 官方推薦的 Go Redis driver。官方 Star 的項目有兩個：Radix.v2 和 Redigo。經過簡單的比較后，選擇了更加輕量級和實現更加優雅的 Radix.v2。

Radix.v2 包是根據功能劃分成一個個的 sub package，每一個 sub package 在一個獨立的子目錄中，結構非常清晰。我的項目中會用到的 sub package 有 redis 和 pool。

由于我想讓這種被 fork 的進程最好簡單點，做的事情單一一些，所以，在沒有深入去看 Radix.v2 的 pool 的實現之前，我選擇了自己實現一個 Redis pool。(這里，就不貼代碼了。后來發現自己實現的 Redis pool 與 Radix.v2 實現的 Redis pool 的原理是一樣的，都是基于 channel 實現的, 遇到的問題也是一樣的。)

不過在測試過程中，發現了一個詭異的問題。在請求過程中經常會報 EOF 錯誤。而且是概率性出現，一會有問題，一會又好了。通過反復的測試，發現 bug 是有規律的，當程序空閑一會后，再進行連續請求，會發生3次失敗，然后之后的請求都能成功，而我的連接池大小設置的是3。再進一步分析，程序空閑300秒 后，再請求就會失敗，發現我的 Redis server 配置了 timeout 300，至此，問題就清楚了。是連接超時 Redis server 主動斷開了連接。客戶端這邊從一個超時的連接請求就會得到 EOF 錯誤。

然后我看了一下 Radix.v2 的 pool 包的源碼，發現這個庫本身并沒有檢測壞的連接，并替換為新server{location/pool{content_by_lua_block{localredis=require"resty.redis"localred=redis:new()localok,err=red:connect("127.0.0.1",6379)ifnotokthenngx.say("failedtoconnect:",err)returnendok,err=red:set("hello","world")ifnotokthenreturnendred:set_keepalive(10000,100)}}}

發現有個 set_keepalive 的方法，查了一下官方文檔，方法的原型是 syntax: ok, err = red:set_keepalive(max_idle_timeout, pool_size) 貌似 max_idle_timeout 這個參數，就是我們所缺少的東西，然后進一步跟蹤源碼，看看里面是怎么保證連接有效的。

function_M.set_keepalive(self,...)localsock=self.sockifnotsockthenreturnnil,"notinitialized"endifself.subscribedthenreturnnil,"subscribedstate"endreturnsock:setkeepalive(...)end

至此，已經清楚了，使用了 tcp 的 keepalive 心跳機制。

于是，通過與 Radix.v2 的作者一些討論，選擇自己在 redis 這層使用心跳機制，來解決這個問題。

四、最后的解決方案

在創建連接池之后，起一個 goroutine，每隔一段 idleTime 發送一個 PING 到 Redis server。其中，idleTime 略小于 Redis server 的 timeout 配置。連接池初始化部分代碼如下：

p,err:=pool.New("tcp",u.Host,concurrency)errHndlr(err)gofunc(){for{p.Cmd("PING")time.Sleep(idelTime*time.Second)}}()

使用 redis 傳輸數據部分代碼如下：

funcredisDo(p*pool.Pool,cmdstring,args...interface{})(reply*redis.Resp,errerror){reply=p.Cmd(cmd,args...)iferr=reply.Err;err!=nil{iferr!=io.EOF{Fatal.Println("redis",cmd,args,"erris",err)}}return}

其中，Radix.v2 連接池內部進行了連接池內連接的獲取和放回，代碼如下：

//Cmdautomaticallygetsoneclientfromthepool,executesthegivencommand//(returningitsresult),andputstheclientbackinthepoolfunc(p*Pool)Cmd(cmdstring,args...interface{})*redis.Resp{c,err:=p.Get()iferr!=nil{returnredis.NewResp(err)}deferp.Put(c)returnc.Cmd(cmd,args...)}

這樣，我們就有了 keepalive 的機制，不會出現 timeout 的連接了，從 redis 連接池里面取出的連接都是可用的連接了。看似簡單的代碼，卻完美的解決了連接池里面超時連接的問題。同時，就算 Redis server 重啟等情況，也能保證連接自動重連。

GO語言（三十）：訪問關系型數據庫（上）

本教程介紹了使用 Godatabase/sql及其標準庫中的包訪問關系數據庫的基礎知識。

您將使用的database/sql包包括用于連接數據庫、執行事務、取消正在進行的操作等的類型和函數。

在本教程中，您將創建一個數據庫，然后編寫代碼來訪問該數據庫。您的示例項目將是有關老式爵士樂唱片的數據存儲庫。

首先，為您要編寫的代碼創建一個文件夾。

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

在 Linux 或 Mac 上：

在 Windows 上：

2、在命令提示符下，為您的代碼創建一個名為 data-access 的目錄。

3、創建一個模塊，您可以在其中管理將在本教程中添加的依賴項。

運行go mod init命令，為其提供新代碼的模塊路徑。

此命令創建一個 go.mod 文件，您添加的依賴項將在其中列出以供跟蹤。

注意： 在實際開發中，您會指定一個更符合您自己需求的模塊路徑。有關更多信息，請參閱一下文章。

GO語言（二十五）：管理依賴項（上）

GO語言（二十六）：管理依賴項（中）

GO語言（二十七）：管理依賴項（下）

接下來，您將創建一個數據庫。

在此步驟中，您將創建要使用的數據庫。您將使用 DBMS 本身的 CLI 創建數據庫和表，以及添加數據。

您將創建一個數據庫，其中包含有關黑膠唱片上的老式爵士樂錄音的數據。

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

1、打開一個新的命令提示符。

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

2、在mysql命令提示符下，創建一個數據庫。

3、切到您剛剛創建的數據庫，以便您可以添加表。

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

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

在此 SQL 代碼中：

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

（2）創建一個album包含四列的表：title、artist和price。每行的id值由 DBMS 自動創建。

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

5、在mysql命令提示符下，運行您剛剛創建的腳本。

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

6、在 DBMS 命令提示符處，使用SELECT語句來驗證您是否已成功創建包含數據的表。

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

現在你已經有了一個包含一些數據的數據庫，開始你的 Go 代碼。

找到并導入一個數據庫驅動程序，該驅動程序會將您通過database/sql包中的函數發出的請求轉換為數據庫可以理解的請求。

1、在您的瀏覽器中，訪問SQLDrivers wiki 頁面以識別您可以使用的驅動程序。

2、使用頁面上的列表來識別您將使用的驅動程序。為了在本教程中訪問 MySQL，您將使用 Go-MySQL-Driver。

3、請注意驅動程序的包名稱 - 此處為github.com/go-sql-driver/mysql.

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

5、進入main.go，粘貼以下代碼導入驅動包。

在此代碼中：

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

（2）導入 MySQL 驅動程序github.com/go-sql-driver/mysql。

導入驅動程序后，您將開始編寫代碼以訪問數據庫。

現在編寫一些 Go 代碼，讓您使用數據庫句柄訪問數據庫。

您將使用指向結構的指針sql.DB，它表示對特定數據庫的訪問。

編寫代碼

1、進入 main.go，在import您剛剛添加的代碼下方，粘貼以下 Go 代碼以創建數據庫句柄。

在此代碼中：

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

該Config結構使代碼比連接字符串更容易閱讀。

（4）調用sql.Open 初始化db變量，傳遞 FormatDSN。

（5）檢查來自 的錯誤sql.Open。例如，如果您的數據庫連接細節格式不正確，它可能會失敗。

為了簡化代碼，您調用log.Fatal結束執行并將錯誤打印到控制臺。在生產代碼中，您會希望以更優雅的方式處理錯誤。

（6）調用DB.Ping以確認連接到數據庫有效。在運行時， sql.Open可能不會立即連接，具體取決于驅動程序。您在Ping此處使用以確認 database/sql包可以在需要時連接。

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

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

文件的頂部現在應該如下所示：

3、保存 main.go。

1、開始跟蹤 MySQL 驅動程序模塊作為依賴項。

使用go get 添加 github.com/go-sql-driver/mysql 模塊作為您自己模塊的依賴項。使用點參數表示“獲取當前目錄中代碼的依賴項”。

2、在命令提示符下，設置Go 程序使用的DBUSER和DBPASS環境變量。

在 Linux 或 Mac 上：

在 Windows 上：

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

連接成功了！

接下來，您將查詢一些數據。

使用Go 語言開發大型 MMORPG 游戲服務器怎么樣

1.為什么golang的開發效率高？

golang是一編譯型的強類型語言，它在開發上的高效率主要來自于后發優勢，不用考慮舊有惡心的歷史，又有一個較高的工程視角。良好的避免了程序員因為“ { 需不需要獨占一行 ”這種革命問題打架，也解決了一部分趁編譯時間找產品妹妹搭訕的階級敵人。

它有自己的包管理機制，工具鏈成熟，從開發、調試到發布都很簡單方便；

有反向接口、defer、coroutine等大量的syntactic sugar；

編譯速度快，因為是強類型語言又有gc，只要通過編譯，非業務毛病就很少了；

它在語法級別上支持了goroutine，這是大家說到最多的內容，這里重點提一下。首先，coroutine并不稀罕，語言并不能超越硬件、操作系統實現神乎其神的功能。golang可以做到事情，其他語言也可以做到，譬如c++，在boost庫里面自己就有的coroutine實現（當然用起來跟其他boost庫一樣惡心）。golang做的事情，是把這一套東西的使用過程簡化了，并且提供了一套channel的通信模式，使得程序員可以忽略諸如死鎖等問題。

goroutine的目的是描述并發編程模型。并發與并行不同，它并不需要多核的硬件支持，它不是一種物理運行狀態，而是一種程序邏輯流程。它的主要目的不是利用多核提高運行效率，而是提供一種更容易理解、不容易出錯的語言來描述問題。

實際上golang默認就是運行在單OS進程上面的，通過指定環境變量GOMAXPROCS才能轉身跑在多OS進程上面。有人提到了網易的pomelo，開源本來是一件很不錯的事情，但是基于自己對callback hell的偏見，我一直持有這種態度：敢用nodejs寫大規模游戲服務器的人，都是真正的勇士 : ) 。

2、Erlang與Golang的coroutine有啥區別，coroutine是啥？

coroutine本質上是語言開發者自己實現的、處于user space內的線程，無論是erlang、還是golang都是這樣。需要解決沒有時鐘中斷；碰著阻塞式i\o，整個進程都會被操作系統主動掛起；需要自己擁有調度控制能力（放在并行環境下面還是挺麻煩的一件事）等等問題。那為啥要廢老大的勁自己做一套線程放user space里面呢？

并發是服務器語言必須要解決的問題；

system space的進程還有線程調度都太慢了、占用的空間也太大了。

把線程放到user space的可以避免了陷入system call進行上下文切換以及高速緩沖更新，線程本身以及切換等操作可以做得非常的輕量。這也就是golang這類語言反復提及的超高并發能力，分分鐘給你開上幾千個線程不費力。

不同的是，golang的并發調度在i/o等易發阻塞的時候才會發生，一般是內封在庫函數內；erlang則更夸張，對每個coroutine維持一個計數器，常用語句都會導致這個計數器進行reduction，一旦到點，立即切換調度函數。

中斷介入程度的不同，導致erlang看上去擁有了preemptive scheduling的能力，而golang則是cooperative shceduling的。golang一旦寫出純計算死循環，進程內所有會話必死無疑；要有大計算量少i\o的函數還得自己主動叫runtime.Sched()來進行調度切換。

3、golang的運行效率怎么樣？

我是相當反感所謂的ping\pong式benchmark，運行效率需要放到具體的工作環境下面考慮。

首先，它再快也是快不過c的，畢竟底下做了那么多工作，又有調度，又有gc什么的。那為什么在那些benchmark里面，golang、nodejs、erlang的響應效率看上去那么優秀呢，響應快，并發強？并發能力強的原因上面已經提到了，響應快是因為大量非阻塞式i\o操作出現的原因。這一點c也可以做到，并且能力更強，但是得多寫不少優質代碼。

然后，針對游戲服務器這種高實時性的運行環境，GC所造成的跳幀問題確實比較麻煩，前面的大神 @達達 有比較詳細的論述和緩解方案，就不累述了 。隨著golang的持續開發，相信應該會有非常大的改進。一是屏蔽內存操作是現代語言的大勢所趨，它肯定是需要被實現的；二是GC算法已經相當的成熟，效率勉勉強強過得去；三是可以通過incremental的操作來均攤cpu消耗。

用這一點點效率損失換取一個更高的生產能力是不是值得呢？我覺得是值得的，硬件已經很便宜了，人生苦短，讓自己的生活更輕松一點吧: )。

4、基于以上的論述，我認為采用go進行小范圍的MMORPG開發是可行的。

如何在go語言中使用redis連接池

1.在創建連接池之后，起一個 go routine，每隔一段 idleTime 發送一個 PING 到 Redis server。其中，idleTime 略小于 Redis server 的 timeout 配置。

2.連接池初始化部分代碼如下：

p, err := pool.New("tcp", u.Host, concurrency) errHndlr(err) go func() { for { p.Cmd("PING") time.Sleep(idelTime * time.Second) } }()

3.使用 redis 傳輸數據部分代碼如下：

func redisDo(p *pool.Pool, cmd string, args ...interface{}) (reply *redis.Resp, err error) { reply = p.Cmd(cmd, args...) if err = reply.Err; err != nil { if err != io.EOF { Fatal.Println("redis", cmd, args, "err is", err) } } return }

4.其中，Radix.v2 連接池內部進行了連接池內連接的獲取和放回，代碼如下：

// Cmd automatically gets one client from the pool, executes the given command // (returning its result), and puts the client back in the pool func (p *Pool) Cmd(cmd string, args ...interface{}) *redis.Resp { c, err := p.Get() if err != nil { return redis.NewResp(err) } defer p.Put(c) return c.Cmd(cmd, args...) }

這樣，就有了系統 keep alive 的機制，不會出現 time out 的連接了，從 redis 連接池里面取出的連接都是可用的連接了。看似簡單的代碼，卻完美的解決了連接池里面超時連接的問題。同時，就算 Redis server 重啟等情況，也能保證連接自動重連。

當前題目：go語言實現ping Go語言實現電梯核心功能
分享網址：http://www.yijiale78.com/article22/hhchjc.html

成都網站建設公司_創新互聯，為您提供建站公司、微信小程序、App開發、商城網站、手機網站建設、品牌網站建設

廣告

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