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}"); }