}
return result;
}
-
- /// <summary>
- /// This method creates a new SqlConnection object and uses the SqlConnection.DataSource
- /// property to return the SQL Server Instance name.
- /// </summary>
- /// <param name="connectionString"></param>
- /// <returns> Returns SQL Server name </returns>
- public static string GetDataSource(string connectionString)
- {
- using (SqlConnection connection = new SqlConnection(connectionString))
- {
- return connection.DataSource;
- }
- }
}
}
public class AADAccessTokenTest
{
private static bool IsAccessTokenSetup() => DataTestUtility.IsAccessTokenSetup();
- private static bool IsAzureServer() => DataTestUtility.IsAzureSqlServer(DataTestUtility.GetDataSource(DataTestUtility.TcpConnStr));
+ private static bool IsAzureServer() => DataTestUtility.IsAzureSqlServer(new SqlConnectionStringBuilder((DataTestUtility.TcpConnStr)).DataSource);
[ConditionalFact(nameof(IsAccessTokenSetup), nameof(IsAzureServer))]
public static void AccessTokenTest()
Console.WriteLine($"Creating Table {s_tableName}");
#endif
// Setup Azure Table
- Helpers.TryExecuteNonQueryAzure(s_connectionString, s_createTableCmd, s_commandTimeout);
+ Helpers.ExecuteNonQueryAzure(s_connectionString, s_createTableCmd, s_commandTimeout);
using (var txScope = new TransactionScope())
{
BulkCopy(s_connectionString);
Console.WriteLine($"Dropping Table {s_tableName}");
#endif
// Drop Azure Table
- Helpers.TryExecuteNonQueryAzure(s_connectionString, "DROP TABLE " + s_tableName, s_commandTimeout);
+ Helpers.ExecuteNonQueryAzure(s_connectionString, "DROP TABLE " + s_tableName, s_commandTimeout);
}
}
return cmd.ExecuteNonQuery();
}
- public static int TryExecuteNonQueryAzure(string strConnectionString, string strCommand, int commandTimeout = 60)
+ public static int ExecuteNonQueryAzure(string strConnectionString, string strCommand, int commandTimeout = 60)
{
using (SqlConnection connection = new SqlConnection(strConnectionString))
using (SqlCommand command = connection.CreateCommand())
{
private string srcConstr = null;
private string dstConstr = null;
- private static bool IsAzureServer() => DataTestUtility.IsAzureSqlServer(DataTestUtility.GetDataSource(DataTestUtility.TcpConnStr));
+ private static bool IsAzureServer() => DataTestUtility.IsAzureSqlServer(new SqlConnectionStringBuilder((DataTestUtility.TcpConnStr)).DataSource);
private static bool AreConnectionStringsSetup() => DataTestUtility.AreConnStringsSetup();
public SqlBulkCopyTest()