BigQueryで行を挿入する

前提

• GCPのプロジェクトIDは myproject。
• BigQuery のデータセットは mydataset、テーブルは mytable。
• テーブル mytable には INTEGER型の id列と STRING型の title列 がある。
• BigQueryにアクセスできるロール(たとえばオーナー)をもったサービスアカウントがある。 → サービスアカウントの作成方法。
• サービスアカウントのキーファイルがC:\gcpfiles\myproject-3bb215c09061.jsonに存在する。→ キーの作成とダウンロード。
• NuGet で Google.Cloud.BigQuery.V2 パッケージをインストールしている。→ NuGetの使用方法
• using Google.Cloud.BigQuery.V2;がソースコードの冒頭付近に記載されている。

var cred = Google.Apis.Auth.OAuth2.GoogleCredential.FromFile(@"C:\gcpfiles\myproject-3bb215c09061.json");
using var client = BigQueryClient.Create("myproject", cred);
//認証情報を環境変数 GOOGLE_APPLICATION_CREDENTIALS から読み取る場合は、次の１行だけでOK。
//参考 https://cloud.google.com/bigquery/docs/quickstarts/quickstart-client-libraries#before-you-begin
//using var client = BigQueryClient.Create("myproject");

var rows = new List<BigQueryInsertRow>();
//insertIdは省略可能です。指定するとBigQueryは最低で1分間同じinsertIdの挿入処理を阻止する場合があるので再実行時に便利です。
rows.Add(new BigQueryInsertRow(insertId:"row1") { { "id", 1 }, { "title", "北海道" } });
//rows.Add(new BigQueryInsertRow(insertId:"row2")…  // ←2行目以降があればこのように追加していけます。

BigQueryInsertResults result = client.InsertRows("mydataset", "mytable", rows);
System.Diagnostics.Debug.WriteLine($"{result.Errors.Count()} errors with {rows.Count} row(s) inserting operation.");

→ Debug.WriteLineが表示される場所

前提

• GCPのプロジェクトIDは myproject。
• BigQuery のデータセットは mydataset、テーブルは mytable。
• テーブル mytable には INTEGER型の id列と STRING型の title列 がある。
• BigQueryにアクセスできるロール(たとえばオーナー)をもったサービスアカウントがある。 → サービスアカウントの作成方法。
• サービスアカウントのキーファイルがC:\gcpfiles\myproject-3bb215c09061.jsonに存在する。→ キーの作成とダウンロード。
• NuGet で Google.Cloud.BigQuery.V2 パッケージをインストールしている。→ NuGetの使用方法
• using Google.Cloud.BigQuery.V2;がソースコードの冒頭付近に記載されている。

var cred = Google.Apis.Auth.OAuth2.GoogleCredential.FromFile(@"C:\gcpfiles\myproject-3bb215c09061.json");
using var client = BigQueryClient.Create("myproject", cred);
//認証情報を環境変数 GOOGLE_APPLICATION_CREDENTIALS から読み取る場合は、次の１行だけでOK。
//参考 https://cloud.google.com/bigquery/docs/quickstarts/quickstart-client-libraries#before-you-begin
//using var client = BigQueryClient.Create("myproject");

string sql = "INSERT mydataset.mytable (id, title) VALUES (123, '徳川家康')";
BigQueryResults result = client.ExecuteQuery(sql, null);

System.Diagnostics.Debug.WriteLine($"{result.NumDmlAffectedRows} row(s) are inserted.");

→ Debug.WriteLineが表示される場所

メモ：１行ずつ複数行を挿入するのはBigQueryでは非推奨です。ものすごく遅いです。参考 SQL アンチパターンの回避

前提

• GCPのプロジェクトIDは myproject。
• BigQuery のデータセットは mydataset、テーブルは mytable。
• テーブル mytable には INTEGER型の id列と STRING型の title列 がある。
• BigQueryにアクセスできるロール(たとえばオーナー)をもったサービスアカウントがある。 → サービスアカウントの作成方法。
• サービスアカウントのキーファイルがC:\gcpfiles\myproject-3bb215c09061.jsonに存在する。→ キーの作成とダウンロード。
• NuGet で Google.Cloud.BigQuery.V2 パッケージをインストールしている。→ NuGetの使用方法
• using Google.Cloud.BigQuery.V2;がソースコードの冒頭付近に記載されている。

var cred = Google.Apis.Auth.OAuth2.GoogleCredential.FromFile(@"C:\gcpfiles\myproject-3bb215c09061.json");
using var client = BigQueryClient.Create("myproject", cred);
//認証情報を環境変数 GOOGLE_APPLICATION_CREDENTIALS から読み取る場合は、次の１行だけでOK。
//参考 https://cloud.google.com/bigquery/docs/quickstarts/quickstart-client-libraries#before-you-begin
//using var client = BigQueryClient.Create("myproject");

string sql = "INSERT mydataset.mytable (id, title) VALUES (1, '北海道'), (2, '青森県')";
BigQueryResults result = client.ExecuteQuery(sql, null);

System.Diagnostics.Debug.WriteLine($"{result.NumDmlAffectedRows} row(s) are inserted.");

→ Debug.WriteLineが表示される場所

ストリーミングを使った挿入の C# のサンプル

ストリーミング挿入

BigQueryで使用できるSQLの構文

標準 SQL のデータ操作言語（DML）ステートメント

C#を使ってシンプルなBigQueryの検索を実行する手順。認証情報の設定などGCP側で必要なことも解説されています。

クイックスタート: クライアント ライブラリの使用

非推奨のやり方と、その代わりに採用すべきやり方。

SQL アンチパターンの回避