分散システムにおける Golang 関数と分散データベース間の相互作用

分散システムでは、Go 関数は分散データベースと対話できます。具体的な手順は次のとおりです。 必要な依存関係をインストールします。データベースに接続するには、spanner.NewClient 関数を使用します。 Query メソッドを使用してクエリを実行し、イテレータを取得します。 Do メソッドを使用して、クエリ結果を反復処理し、データを処理します。クエリが完了したら、Close メソッドを使用して接続を閉じます。

#分散システムにおける Go 関数と分散データベース間の対話

分散システムでは、Go 関数が分散データベースと対話することが一般的な要件です。この記事では、Go コードを使用して分散データベースに接続し、クエリを実行する方法を説明します。

依存関係のインストール

最初のステップは、必要な依存関係をインストールすることです:

import (
    "context"
    "fmt"
    "log"

    "cloud.google.com/go/spanner"
)

データベースに接続

データベースに接続するには、## を使用します。 #spanner.NewClient

関数: <pre class='brush:php;toolbar:false;'>client, err := spanner.NewClient(context.Background(), &quot;projects/my-project&quot;, &quot;instances/my-instance&quot;, &quot;databases/my-database&quot;) if err != nil { log.Fatal(err) }</pre>クエリの実行

クエリを実行するには、

Query

メソッド: <pre class='brush:php;toolbar:false;'>stmt := spanner.Statement{SQL: `SELECT * FROM Singers`} iter := client.Single().Query(context.Background(), stmt) defer iter.Stop()</pre>

iter

は、クエリ結果を反復処理するイテレータです。 結果の処理

結果を処理するには、

Do

メソッドを使用してください: <pre class='brush:php;toolbar:false;'>for { row, err := iter.Next() if err == iterator.Done { break } if err != nil { log.Fatal(err) } var singerId int64 var firstName string var lastName string if err := row.ColumnByName(&quot;SingerId&quot;, &amp;singerId); err != nil { log.Fatal(err) } if err := row.ColumnByName(&quot;FirstName&quot;, &amp;firstName); err != nil { log.Fatal(err) } if err := row.ColumnByName(&quot;LastName&quot;, &amp;lastName); err != nil { log.Fatal(err) } fmt.Printf(&quot;%d %s %s\n&quot;, singerId, firstName, lastName) }</pre>接続を閉じます

クエリが完了しました。閉じてください。データベースへの接続:

client.Close()

実用的なケース

以下は、Cloud Spanner データベースに接続してクエリを実行する方法を示す完全な Go コード例です。リーリー

以上が分散システムにおける Golang 関数と分散データベース間の相互作用の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。