in Amazon.QLDB.Driver.IntegrationTests/StatementExecutionTests.cs [359:397]
public void Execute_QuerySingleField_ReturnsSingleField()
{
// Given.
// Create Ion struct to insert.
IIonValue ionStruct = ValueFactory.NewEmptyStruct();
ionStruct.SetField(Constants.ColumnName, ValueFactory.NewString(Constants.SingleDocumentValue));
var query = $"INSERT INTO {Constants.TableName} ?";
var count = qldbDriver.Execute(txn =>
{
var result = txn.Execute(query, ionStruct);
var count = 0;
foreach (var row in result)
{
count++;
}
return count;
});
Assert.AreEqual(1, count);
// When.
var searchQuery = $@"SELECT VALUE {Constants.ColumnName} FROM {Constants.TableName}
WHERE {Constants.ColumnName} = '{Constants.SingleDocumentValue}'";
var value = qldbDriver.Execute(txn =>
{
var result = txn.Execute(searchQuery);
var value = "";
foreach (var row in result)
{
value = row.StringValue;
}
return value;
});
// Then.
Assert.AreEqual(Constants.SingleDocumentValue, value);
}