fix(csharp/src/Drivers/BigQuery): Adjust default dataset id

csharp/src/Drivers/BigQuery/BigQueryParameters.cs

@@ -91,9 +91,8 @@ internal class BigQueryConstants
         // default value per https://pkg.go.dev/cloud.google.com/go/bigquery#section-readme
         public const string DetectProjectId = "*detect-project-id*";
 
-        // Reuse what the ODBC driver already has in place, in case a caller
-        // has permission issues trying to create a new dataset
-        public const string DefaultLargeDatasetId = "_bqodbc_temp_tables";
+        // matches the pattern for odbc, but for adbc
+        public const string DefaultLargeDatasetId = "_bqadbc_temp_tables";
 
         public const string PublicProjectId = "bigquery-public-data";
     }

csharp/src/Drivers/BigQuery/BigQueryStatement.cs

@@ -485,15 +485,11 @@ private TableReference TryGetLargeDestinationTableReference(string datasetId, Ac
                 {
                     activity?.AddBigQueryTag("large_results.dataset.try_create", datasetId);
                     DatasetReference reference = this.Client.GetDatasetReference(datasetId);
+
                     BigQueryDataset bigQueryDataset = new BigQueryDataset(this.Client, new Dataset()
                     {
                         DatasetReference = reference,
-                        DefaultTableExpirationMs = (long)TimeSpan.FromDays(1).TotalMilliseconds,
-                        Labels = new Dictionary<string, string>()
-                        {
-                            // lower case, no spaces or periods per https://cloud.google.com/bigquery/docs/labels-intro
-                            { "created_by", this.bigQueryConnection.DriverName.ToLowerInvariant().Replace(" ","_") + "_v_" + AssemblyVersion.Replace(".","_") }
-                        }
+                        DefaultTableExpirationMs = (long)TimeSpan.FromDays(1).TotalMilliseconds
                     });
 
                     dataset = this.Client.CreateDataset(datasetId, bigQueryDataset.Resource);

csharp/src/Drivers/BigQuery/readme.md

@@ -93,7 +93,7 @@ The following parameters can be used to configure the driver behavior. The param
     Include the `bigquery-public-data` project ID with the list of project IDs.
 
 **adbc.bigquery.large_results_dataset**<br>
-&nbsp;&nbsp;&nbsp;&nbsp;Optional. Sets the dataset ID to use for large results. The dataset needs to be in the same region as the data being queried. If no value is specified, the driver will attempt to use or create `_bqodbc_temp_tables`. A randomly generated table name will be used for the DestinationTable.
+&nbsp;&nbsp;&nbsp;&nbsp;Optional. Sets the dataset ID to use for large results. The dataset needs to be in the same region as the data being queried. If no value is specified, the driver will attempt to use or create `_bqadbc_temp_tables`. A randomly generated table name will be used for the DestinationTable.
 
 **adbc.bigquery.large_results_destination_table**<br>
 &nbsp;&nbsp;&nbsp;&nbsp;Optional. Sets the [DestinationTable](https://cloud.google.com/dotnet/docs/reference/Google.Cloud.BigQuery.V2/latest/Google.Cloud.BigQuery.V2.QueryOptions#Google_Cloud_BigQuery_V2_QueryOptions_DestinationTable) value of the QueryOptions if configured. Expects the format to be `{projectId}.{datasetId}.{tableId}` to set the corresponding values in the [TableReference](https://github.com/googleapis/google-api-dotnet-client/blob/6c415c73788b848711e47c6dd33c2f93c76faf97/Src/Generated/Google.Apis.Bigquery.v2/Google.Apis.Bigquery.v2.cs#L9348) class.
@@ -169,8 +169,8 @@ a dataset using the `adbc.bigquery.large_results_dataset` parameter.
 Behavior:
 - If a destination table is explicitly set, the driver will use that value.
 - If only a dataset value is set, the driver will attempt to retrieve the dataset. If the dataset does not exist, the driver will attempt to
-  create it. The default table expiration will be set to 1 day and a `created_by` label will be included with the driver name and version that created the dataset. For example `created_by : adbc_bigquery_driver_v_0_19_0_0`. A randomly generated name will be used for the table name.
-- If a destination table and a dataset are not specified, the driver will attempt to use or create the `_bqodbc_temp_tables` dataset using the same defaults and label specified above. A randomly generated name will be used for the table name.
+  create it. The default table expiration will be set to 1 day. A randomly generated name will be used for the table name.
+- If a destination table and a dataset are not specified, the driver will attempt to use or create the `_bqadbc_temp_tables` dataset using the same defaults and label specified above. A randomly generated name will be used for the table name.
 
 ## Permissions
 

csharp/test/Drivers/BigQuery/BigQueryTestConfiguration.cs

@@ -36,6 +36,7 @@ public BigQueryTestEnvironment()
         {
             AllowLargeResults = false;
             IncludeTableConstraints = true;
+            ParallelQueries = new List<ParallelQuery>();
         }
 
         [JsonPropertyName("projectId")]
@@ -130,6 +131,30 @@ public BigQueryTestEnvironment()
 
         [JsonPropertyName("entraConfiguration")]
         public EntraConfiguration? EntraConfiguration { get; set; }
+
+        /// <summary>
+        /// The number of times to repeat the parallel runs.
+        /// </summary>
+        [JsonPropertyName("numberOfParallelRuns")]
+        public int NumberOfParallelRuns { get; set; }
+
+        [JsonPropertyName("queries")]
+        public List<ParallelQuery> ParallelQueries { get; set; }
+    }
+
+    class ParallelQuery
+    {
+        /// <summary>
+        /// The query to run.
+        /// </summary>
+        [JsonPropertyName("query")]
+        public string Query { get; set; } = string.Empty;
+
+        /// <summary>
+        /// The number of expected results from the query.
+        /// </summary>
+        [JsonPropertyName("expectedResults")]
+        public long ExpectedResultsCount { get; set; }
     }
 
     class EntraConfiguration

csharp/test/Drivers/BigQuery/DriverTests.cs

@@ -299,6 +299,36 @@ public void CanExecuteQuery()
             }
         }
 
+        /// <summary>
+        /// Validates if the driver can connect to a live server and
+        /// parse the results.
+        /// </summary>
+        [SkippableFact, Order(6)]
+        public void CanExecuteParallelQueries()
+        {
+            foreach (BigQueryTestEnvironment environment in _environments)
+            {
+                AdbcConnection adbcConnection = GetAdbcConnection(environment.Name);
+
+                Parallel.For(0, environment.NumberOfParallelRuns, (i) =>
+                {
+                    Parallel.ForEach(environment.ParallelQueries, pq =>
+                    {
+                        using (AdbcStatement statement = adbcConnection.CreateStatement())
+                        {
+                            statement.SqlQuery = pq.Query;
+
+                            QueryResult queryResult = statement.ExecuteQuery();
+
+                            _outputHelper?.WriteLine($"({i}) {DateTime.Now.Ticks} - {queryResult.RowCount} results for {pq.Query}");
+
+                            Tests.DriverTests.CanExecuteQuery(queryResult, pq.ExpectedResultsCount, environment.Name);
+                        }
+                    });
+                });
+            }
+        }
+
         private AdbcConnection GetAdbcConnection(string? environmentName)
         {
             if (string.IsNullOrEmpty(environmentName))