Goクライアントのチュートリアル

go get github.com/machbase/neo-server/v8

import (
    "context"
    "fmt"
    "time"
    
    "github.com/machbase/neo-server/v8/api"
    "github.com/machbase/neo-server/v8/api/machgo"
)

conf := &machgo.Config{
    Host:         "127.0.0.1",    // Machbaseサーバーのホスト
    Port:         5656,           // Machbaseサーバーのポート
    MaxOpenConn:  -1,             // 接続数の上限, -1: 無制限
    MaxOpenQuery: -1,             // 同時実行クエリ数の上限
    StatementCache: api.StatementCacheAuto,
}

// 設定からデータベースインスタンスを作成
db, err := machgo.NewDatabase(conf)
if err != nil {
    panic(err)
}

// 繰り返すSQLが多い接続：ステートメントキャッシュを有効化
connA, err := db.Connect(
    ctx,
    api.WithPassword("sys", "manager"),
    api.WithStatementCache(api.StatementCacheAuto),
)
if err != nil {
    panic(err)
}
defer connA.Close()

// 動的SQLが多い接続：この接続だけでキャッシュを無効化
connB, err := db.Connect(
    ctx,
    api.WithPassword("sys", "manager"),
    api.WithStatementCache(api.StatementCacheOff),
)
if err != nil {
    panic(err)
}
defer connB.Close()

// 大量スキャンのワークロード用にプリフェッチサイズを増やす
connC, err := db.Connect(
    ctx,
    api.WithPassword("sys", "manager"),
    api.WithFetchRows(5000),
)
if err != nil {
    panic(err)
}
defer connC.Close()

ctx := context.Background()
conn, err := db.Connect(ctx, api.WithPassword("username", "password"))
if err != nil {
    panic(err)
}
defer conn.Close() // 処理の完了時に必ず接続を閉じます

var name = "tag1"
var tm time.Time
var val float64

// 単一行を返すクエリを実行
row := conn.QueryRow(ctx, 
    `SELECT time, value FROM example_table WHERE name = ? ORDER BY TIME DESC LIMIT 1`, 
    name)

// クエリの実行エラーを確認
if err := row.Err(); err != nil {
    panic(err)
}

// 結果を変数にスキャン
if err := row.Scan(&tm, &val); err != nil {
    panic(err)
}

// 表示用にローカルタイムゾーンに変換
tm = tm.In(time.Local)
fmt.Println("name:", name, "time:", tm, "value:", val)

var name = "tag1"
var tm time.Time
var val float64

// 複数行を返すクエリを実行
rows, err := conn.Query(ctx, 
    `SELECT time, value FROM example_table WHERE name = ? ORDER BY TIME DESC LIMIT 10`, 
    name)
if err != nil {
    panic(err)
}
defer rows.Close() // 重要：リソースを解放するため、必ずrowsを閉じます

// 返されたすべての行を反復処理
for rows.Next() {
    if err := rows.Scan(&tm, &val); err != nil {
        panic(err)
    }
    tm = tm.In(time.Local)
    fmt.Println("name:", name, "time:", tm, "value:", val)
}

var name = "tag1"
var tm = time.Now()
var val = 3.14

// INSERT文を実行
result := conn.Exec(ctx, 
    `INSERT INTO example_table VALUES(?, ?, ?)`, 
    name, tm, val)

// 実行エラーを確認
if err := result.Err(); err != nil {
    panic(err)
}

// 実行結果を取得
fmt.Println("RowsAffected:", result.RowsAffected()) 
fmt.Println("Message:", result.Message())

// 重要：Appender専用の接続を使用
// 使用中のAppenderがある接続を他の処理に使用しないでください
conn, err := db.Connect(ctx, api.WithPassword("username", "password"))
if err != nil {
    panic(err)
}
defer conn.Close()

// 対象テーブルのAppenderを作成
apd, err := conn.Appender(ctx, "example_table")
if err != nil {
    panic(err)
}
defer apd.Close() // 残りのデータをフラッシュするため、必ずAppenderを閉じます

// 高速な一括挿入
for i := range 10_000 {
    err := apd.Append("tag1", time.Now(), 1.23*float64(i))
    if err != nil {
        panic(err)
    }
}

apd, err := conn.Appender(ctx, "example_table")
if err != nil {
    panic(err)
}
defer apd.Close()

apd.WithBatchMaxBytes(1024 * 1024).          // 1MB
    WithBatchMaxRows(2000).                  // 行数のしきい値
    WithBatchMaxDelay(500 * time.Millisecond) // 遅延のしきい値

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "github.com/machbase/neo-server/v8/api"
    "github.com/machbase/neo-server/v8/api/machgo"
)

func main() {
    // データベースの接続設定
    conf := &machgo.Config{
        Host: "127.0.0.1",
        Port: 5656,
        MaxOpenConn: 10,
        MaxOpenQuery: 5,
    }
    
    db, err := machgo.NewDatabase(conf)
    if err != nil {
        panic(err)
    }
    ctx := context.Background()
    
    // データベースに接続
    conn, err := db.Connect(ctx, api.WithPassword("sys", "manager"))
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()
    
    // サンプルテーブルの作成
    result := conn.Exec(ctx, `
        CREATE TAG TABLE IF NOT EXISTS sample_data (
            name VARCHAR(100) primary key,
            time DATETIME basetime,
            value DOUBLE
        )
    `)
    if err := result.Err(); err != nil {
        log.Fatal(err)
    }
    
    // サンプルデータの挿入
    for i := 0; i < 5; i++ {
        result := conn.Exec(ctx,
            `INSERT INTO sample_data VALUES (?, ?, ?)`,
            fmt.Sprintf("sensor_%d", i), time.Now(), float64(i)*1.5)
        if err := result.Err(); err != nil {
            log.Fatal(err)
        }
    }
    
    // データの検索
    rows, err := conn.Query(ctx, `SELECT name, time, value FROM sample_data ORDER BY time`)
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()
    
    fmt.Println("Retrieved data:")
    for rows.Next() {
        var name string
        var tm time.Time
        var value float64
        
        if err := rows.Scan(&name, &tm, &value); err != nil {
            log.Fatal(err)
        }
        tm = tm.Local()
        fmt.Printf("Name: %s, Time: %s, Value: %.2f\n", 
            name, tm.Format(time.RFC3339), value)
    }
}