transaction_t.cc File Reference

#include "cetlib/container_algorithms.h"
#include "cetlib/sqlite/Connection.h"
#include "cetlib/sqlite/ConnectionFactory.h"
#include "cetlib/sqlite/Transaction.h"
#include "cetlib/sqlite/column.h"
#include "cetlib/sqlite/create_table.h"
#include "cetlib/sqlite/insert.h"
#include "cetlib/sqlite/query_result.h"
#include "cetlib/sqlite/select.h"
#include "cetlib_except/exception.h"
#include <array>
#include <cassert>
#include <iostream>
#include <memory>
#include <string>
#include <vector>

Go to the source code of this file.

Functions
int	main ()

Function Documentation

int main

(

void

)

Definition at line 44 of file transaction_t.cc.

{
  try {
    ConnectionFactory factory;
    unique_ptr<Connection> c{factory.make_connection(":memory:")};
    // Test normal transaction
    string const table_name{"Workers"};
    create_table(
      *c, table_name, column<string>{"FirstName"}, column<string>{"LastName"});
    {
      Transaction txn{*c};
      for (auto const& worker : names) {
        insert_into(*c, table_name).values(worker[0], worker[1]);
      }
      txn.commit();
      check_table_contents(*c, table_name);
    }
    string const table_name2{"Workers2"};
    create_table(
      *c, table_name2, column<string>{"FirstName"}, column<string>{"LastName"});
    // Test select before commit is called
    {
      Transaction txn{*c};
      for (auto const& worker : names) {
        insert_into(*c, table_name2).values(worker[0], worker[1]);
      }
      // Calling a SELECT before the transaction is committed implicitly ends
      // the transaciton.
      check_table_contents(*c, table_name2);
      txn.commit(); // Call commit to avoid the error emitted from the
      // ~Transaction().
    }
    // Fail to commit before transaction destroyed (due to exception
    // throw)
    {
      try {
        Transaction txn{*c};
        insert_into(*c, table_name2).values("Johnny", "Davis");
        throw 1.0;
      }
      catch (double) {
      }
      check_table_contents(*c, table_name2);
    }
  }
  catch (cet::exception const& e) {
    cerr << e.what() << '\n';
    return 1;
  }
  catch (...) {
    cerr << "Unknown exception caught.\n";
    return 2;
  }
}