Golang で非同期データベース操作を行うにはどうすればよいですか?
Golang で非同期データベース操作を実行するには、主に 2 つの方法があります: コルーチンを使用する方法: バックグラウンド スレッドでクエリを非同期に実行する方法。クエリがキャンセルされた場合、プログラムは「クエリがキャンセルされました」というメッセージを出力します。ゴルーチン プールを使用する: 大量の並列クエリを処理するアプリケーションの場合、ゴルーチン プールはコルーチンを再利用してタスクを実行できるため、パフォーマンスを向上させることができます。
Golang での非同期データベース操作
非同期データベース操作を使用すると、アプリケーションはクエリ結果を待機している間も他のタスクの実行を続けることができます。これにより、特に大量のデータベース I/O を伴うアプリケーションのパフォーマンスが大幅に向上します。
コルーチンの使用
Golang で非同期データベース操作を実行する一般的な方法は、コルーチン (goroutine
) を使用することです。コルーチンは、同時に実行される軽量のスレッドであり、メインスレッドと同時に実行できます。
次のコード例は、コルーチンを使用してデータベース クエリを非同期的に実行する方法を示しています:
package main import ( "context" "database/sql" "fmt" "time" ) func main() { // 打开数据库连接 db, err := sql.Open("postgres", "user=postgres password=my-password database=database host=localhost port=5432") if err != nil { panic(err) } defer db.Close() // 创建用于取消查询的上下文 ctx := context.Background() // 创建协程 go func() { // 使用 ctx.Done() 检查是否已取消查询 for { select { case <-ctx.Done(): fmt.Println("查询已取消") return default: // 执行查询 rows, err := db.QueryContext(ctx, "SELECT name FROM people") if err != nil { fmt.Println(err) continue } // 迭代查询结果 for rows.Next() { var name string if err := rows.Scan(&name); err != nil { fmt.Println(err) continue } fmt.Println(name) } rows.Close() } } }() // 等待一段时间,然后取消查询 time.Sleep(time.Second * 2) ctx.Cancel() }
このコードは、バックグラウンド コルーチンでデータベース クエリを非同期的に実行します。クエリが完了する前にキャンセルされた場合、コードは「クエリがキャンセルされました」というメッセージを出力します。
Goroutine プールを使用する
大量の並列データベース クエリを処理する必要があるアプリケーションの場合、Goroutine プールを使用するとパフォーマンスが向上します。 goroutine プールは、タスクを実行するために再利用できる管理された goroutine のセットです。
次のコード例は、非同期データベース操作に goroutine プールを使用する方法を示しています:
package main import ( "context" "database/sql" "fmt" "sync" "time" ) func main() { // 创建 goroutine pool pool := sync.Pool{ New: func() interface{} { return &sql.DB{} }, } // 打开数据库连接 db := pool.Get().(*sql.DB) defer pool.Put(db) // 创建用于取消查询的上下文 ctx := context.Background() // 创建 goroutine go func() { // 使用 ctx.Done() 检查是否已取消查询 for { select { case <-ctx.Done(): fmt.Println("查询已取消") return default: // 执行查询 rows, err := db.QueryContext(ctx, "SELECT name FROM people") if err != nil { fmt.Println(err) continue } // 迭代查询结果 for rows.Next() { var name string if err := rows.Scan(&name); err != nil { fmt.Println(err) continue } fmt.Println(name) } rows.Close() } } }() // 等待一段时间,然后取消查询 time.Sleep(time.Second * 2) ctx.Cancel() }
このコードは前の例と似ていますが、コルーチンを管理するために goroutine プールを使用します。これにより、新しいコルーチン作成のオーバーヘッドが軽減され、パフォーマンスが向上します。
以上がGolang で非同期データベース操作を行うにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

ホットAIツール

Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。

Undress AI Tool
脱衣画像を無料で

Clothoff.io
AI衣類リムーバー

Video Face Swap
完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。

人気の記事

ホットツール

メモ帳++7.3.1
使いやすく無料のコードエディター

SublimeText3 中国語版
中国語版、とても使いやすい

ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境

ドリームウィーバー CS6
ビジュアル Web 開発ツール

SublimeText3 Mac版
神レベルのコード編集ソフト(SublimeText3)

ホットトピック











Apple の最新リリースの iOS18、iPadOS18、および macOS Sequoia システムでは、さまざまな理由で紛失または破損した写真やビデオをユーザーが簡単に回復できるように設計された重要な機能が写真アプリケーションに追加されました。この新機能では、写真アプリのツール セクションに「Recovered」というアルバムが導入され、ユーザーがデバイス上に写真ライブラリに含まれていない写真やビデオがある場合に自動的に表示されます。 「Recovered」アルバムの登場により、データベースの破損、カメラ アプリケーションが写真ライブラリに正しく保存されない、または写真ライブラリを管理するサードパーティ アプリケーションによって失われた写真やビデオに対する解決策が提供されます。ユーザーはいくつかの簡単な手順を実行するだけで済みます

MySQLi を使用して PHP でデータベース接続を確立する方法: MySQLi 拡張機能を含める (require_once) 接続関数を作成する (functionconnect_to_db) 接続関数を呼び出す ($conn=connect_to_db()) クエリを実行する ($result=$conn->query()) 閉じる接続 ( $conn->close())

PHP でデータベース接続エラーを処理するには、次の手順を使用できます。 mysqli_connect_errno() を使用してエラー コードを取得します。 mysqli_connect_error() を使用してエラー メッセージを取得します。これらのエラー メッセージをキャプチャしてログに記録することで、データベース接続の問題を簡単に特定して解決でき、アプリケーションをスムーズに実行できるようになります。

非同期および非ブロッキング技術を使用して、従来の例外処理を補完し、より応答性が高く効率的な Java アプリケーションを作成できます。 非同期例外処理: 別のスレッドまたはプロセスで例外を処理し、メイン スレッドが実行を継続できるようにして、ブロックを回避します。ノンブロッキング例外処理: I/O 操作が失敗した場合のイベント駆動型の例外処理が含まれ、スレッドのブロックを回避し、イベント ループで例外を処理できるようにします。

Golang でデータベース コールバック関数を使用すると、次のことを実現できます。 指定されたデータベース操作が完了した後にカスタム コードを実行します。追加のコードを記述せずに、個別の関数を通じてカスタム動作を追加します。コールバック関数は、挿入、更新、削除、クエリ操作に使用できます。コールバック関数を使用するには、sql.Exec、sql.QueryRow、または sql.Query 関数を使用する必要があります。

JSON データは、gjson ライブラリまたは json.Unmarshal 関数を使用して MySQL データベースに保存できます。 gjson ライブラリは、JSON フィールドを解析するための便利なメソッドを提供します。json.Unmarshal 関数には、JSON データをアンマーシャリングするためのターゲット型ポインターが必要です。どちらの方法でも、SQL ステートメントを準備し、データをデータベースに永続化するために挿入操作を実行する必要があります。

Go 標準ライブラリのデータベース/SQL パッケージを通じて、MySQL、PostgreSQL、SQLite などのリモート データベースに接続できます。データベース接続情報を含む接続文字列を作成します。 sql.Open() 関数を使用してデータベース接続を開きます。 SQL クエリや挿入操作などのデータベース操作を実行します。 defer を使用してデータベース接続を閉じ、リソースを解放します。

PHP データベース接続ガイド: MySQL: MySQLi 拡張機能をインストールし、接続 (サーバー名、ユーザー名、パスワード、データベース名) を作成します。 PostgreSQL: PgSQL 拡張機能をインストールし、接続 (ホスト、データベース名、ユーザー、パスワード) を作成します。 Oracle: OracleOCI8 拡張機能をインストールし、接続 (サーバー名、ユーザー名、パスワード) を作成します。実際のケース: MySQL データ、PostgreSQL クエリ、OracleOCI8 更新レコードを取得します。
