#include <tip/db/pg.hpp>

using namespace tip::db::pg;

// Register conntions
db_service::add_connection("main=user@localhost:5432[the_database]");
db_service::add_connection("logs=user@localhost:5432[logs_db]");

// Run the service
db_service::run(); // Will block the thread

// Execute queries
db_service::begin(            // Start a transaction
  "main"_db,                  // Database alias
  [](transaction_ptr tran)    // Function to be run inside a transaction
  {
    query(
      tran,                                 // Transaction handle
      "select * from pg_catalog.pg_type"    // SQL statement
    )   
    ([](transaction_ptr tran, resultset res, bool complete) // Query results handler
    {
      for (auto field_desc : 
              res.row_description()) {    // Iterate the field descriptions
        std::cout << field_desc.name << "\t";
      }
      std::cout << "\n";
      for (auto row : res) {              // Iterate the resultset
        int a, b;
        row.to(std::tie(a, b));           // Extract query result row to a tuple
        for (auto field : row) {          // Iterate the fields of the row
          std::cout << field.coalesce( "null" ) 
              << "\t";
        }
      }
    },
    [](db_error const& error)             // Query error handler
    {
    });
  },
  [](db_error cosnt& error)   // Function to be called in case of a transaction error
  {
  }
);