AthenaDb.DbConnection 0.2.2

AthenaDb.DbConnection

DbConnection, DbCommand, and DataReader implementation for Amazon Athena

Installation

dotnet add package AthenaDb.DbConnection

Athena + Dapper usage

 // create IDbConnection to Athena
 using (var athenaConnection = new AthenaDbConnection(athenaDb, athenaTemp))
 {
 await athenaConnection.OpenAsync();

 // construct some athena query
 var query = "SELECT * FROM orders limit 3000";

 // use Dapper to process athena results :)
 var res = await athenaConnection.QueryAsync<Order>(query);

 var rows = 0;
 foreach (var row in res)
 {
 System.Console.WriteLine(
 $"[{rows}] orderId: {row.OrderId}, clientEmail: {row.ClientEmail}, amount: {row.Amount}; modified: {row.Modified}");
 rows++;
 }

 System.Console.WriteLine($"Rows readed {rows}");
 }