Lindorm：基於Go database/sql介面的應用開發

前提條件

• 已下載並安裝Go環境，建議安裝Go 1.17及以上版本。

• 已將用戶端IP地址添加至Lindorm執行個體的白名單中，具體操作，請參見設定白名單。

使用限制

本文操作僅適用於Lindorm寬表模式，不支援Lindorm寬表Serverless模式。

操作步驟

1. 在Go專案程式的go.mod檔案中添加以下依賴：

   require github.com/apache/calcite-avatica-go/v5 v5.0.0
   replace github.com/apache/calcite-avatica-go/v5 => github.com/aliyun/alibabacloud-lindorm-go-sql-driver/v5 v5.0.6

2. 在.go檔案中添加資料庫驅動的依賴，內容如下：

   import (
       avatica "github.com/apache/calcite-avatica-go/v5"
   )

3. 在.go檔案的main方法中初始化串連池並配置以下參數，樣本如下：

   databaseUrl := "http://localhost:30060" 
   
   conn := avatica.NewConnector(databaseUrl).(*avatica.Connector)
   conn.Info = map[string]string{
       "user":     "sql",     
       "password": "test",   
       "database": "default", 
   }
   db := sql.OpenDB(conn)
   // 設定串連池參數
   db.SetConnMaxIdleTime(8 * time.Minute)
   db.SetMaxOpenConns(20)
   db.SetMaxIdleConns(2)

   參數說明如下：

   參數	是否必選	說明
   databaseUrl	是	Lindorm寬表SQL地址，例如：http://ld-bp12pc23yfb38****-proxy-lindorm.lindorm.rds.aliyuncs.com:30060。查看方法請參見查看寬表引擎串連地址。
   user	是	訪問寬表引擎的使用者名稱。
   password	是	訪問寬表引擎的密碼，如果您忘記了密碼，可以通過Lindorm寬表引擎的叢集管理系統修改密碼，具體請參見修改使用者密碼。
   database	是	資料庫名。
   SetConnMaxIdleTime	否	設定最大空閑時間。預設值為0，表示不逾時。
   SetMaxOpenConns	否	設定串連池中允許的最大串連數。預設值為0，表示沒有限制。
   SetMaxIdleConns	否	設定串連池中允許的最大空閑串連數。預設值為2。

4. 在寬表引擎中進行建立表、寫入資料、查詢資料、刪除資料操作，樣本如下：

   • 建立表

     _, err := db.Exec("create table if not exists user_test(id int, name varchar,age int, primary key(id))")
     if err != nil {
         fmt.Println("create table error ", err)
         return
     }

   • 寫入資料

     • 方法一：直接寫入資料。

       _, err = db.Exec("upsert into user_test(id,name,age) values(1,'zhangsan',17)")
       if err != nil {
           fmt.Println("insert data error", err)
           return
       }

     • 方法二：通過綁定參數的方式進行寫入資料。

       stmt, err := db.Prepare("upsert into user_test(id,name,age) values(?,?,?)")
       if err != nil {
           fmt.Println("prepare error", err)
           return
       }
       _, err = stmt.Exec(1, "zhangsan", 17)
       if err != nil {
           fmt.Println("upsert error", err)
           return
       }

   • 查詢資料

     • 方法一：直接查詢資料。

       rows, err := db.Query("select * from user_test")
       if err != nil {
           fmt.Println("query data error", err)
           return
       }
       defer rows.Close()
       var id int
       var name string
       var age int
       for rows.Next() {
           err = rows.Scan(&id, &name, &age)
           if err != nil {
                  fmt.Println("scan data error", err)
               return
           }
           fmt.Println("id:", id, "name:", name, "age:", age)
       }

     • 方法二：通過綁定參數的方式執行參數化查詢。

       stmt, err = db.Prepare("select * from user_test where id=?")
       if err != nil {
           fmt.Println("prepare error", err)
           return
       }
       rows, err := stmt.Query(1)
       if err != nil {
           fmt.Println("query data error", err)
           return
       }
       defer rows.Close()
       var id int
       var name string
       var age int
       for rows.Next() {
           err = rows.Scan(&id, &name, &age)
           if err != nil {
                  fmt.Println("scan data error", err)
               return
           }
           fmt.Println("id:", id, "name:", name, "age:", age)
       }

   • 刪除資料

     _, err = db.Exec("delete from user_test where id=1")
     if err != nil {
         fmt.Println("delete data error", err)
         return
     }

   說明

   • 在業務應用的實現中，對於寫入或查詢語句相對固化的情境，推薦使用上述綁定參數的方式，使用Prepare之後的stmt對象執行寫入或查詢。因為這種方式對於相同的語句只會執行一次SQL的解析、改寫、最佳化邏輯，有助於提升執行效能。

   • 完整的範例程式碼請參見程式碼範例和通過綁定參數寫入和查詢資料。