in Amazon.QLDB.Driver.IntegrationTests/StatementExecutionTests.cs [86:136]
public void Execute_DropExistingTable_TableDropped()
{
// Given.
var create_table_query = $"CREATE TABLE {Constants.CreateTableName}";
var create_table_count = qldbDriver.Execute(txn =>
{
var result = txn.Execute(create_table_query);
var count = 0;
foreach (var row in result)
{
count++;
}
return count;
});
Assert.AreEqual(1, create_table_count);
// Execute ListTableNames() to ensure table is created.
var result = qldbDriver.ListTableNames();
var tables = new List<string>();
foreach (var row in result)
{
tables.Add(row);
}
Assert.IsTrue(tables.Contains(Constants.CreateTableName));
// When.
var drop_table_query = $"DROP TABLE {Constants.CreateTableName}";
var drop_table_count = qldbDriver.Execute(txn =>
{
var result = txn.Execute(drop_table_query);
var count = 0;
foreach (var row in result)
{
count++;
}
return count;
});
Assert.AreEqual(1, drop_table_count);
// Then.
tables.Clear();
var updated_tables_result = qldbDriver.ListTableNames();
foreach (var row in updated_tables_result)
{
tables.Add(row);
}
Assert.IsFalse(tables.Contains(Constants.CreateTableName));
}