test_pqxx/test_pqxx.cpp

   1 #include <iostream>
   2 #include <pqxx/pqxx>
   3 #include "pqxx_traits.hpp"
   4 #include "test_gen.hpp"
   5
   6 using namespace std;
   7 using namespace pqxx;
   8
   9 typedef sqlgg<pqxx_traits> gen;
  10
  11 int main()
  12 {
  13         try
  14         {
  15                 connection C("dbname=test");
  16                 cout << "Connected to " << C.dbname() << endl;
  17                 work W(C);
  18
  19     result R;
  20     R = W.exec("DROP TABLE employee");
  21     gen::create_employee(W);
  22
  23     gen::insert_employee(W,"john",2);
  24     gen::insert_employee(W,"jack",3);
  25     gen::insert_employee(W,"bob",4);
  26                 R = W.exec("SELECT name FROM employee");
  27
  28                 cout << "Found " << R.size() << " employees:" << endl;
  29                 for (result::const_iterator r = R.begin();
  30                      r != R.end();
  31                      ++r)
  32                 {
  33                         cout << r[0].c_str() << endl;
  34                 }
  35
  36                 cout << "Doubling all employees' salaries..." << endl;
  37                 W.exec("UPDATE employee SET salary=salary*2");
  38
  39                 cout << "Making changes definite: ";
  40                 W.commit();
  41                 cout << "ok." << endl;
  42         }
  43         catch (const exception &e)
  44         {
  45                 cerr << e.what() << endl;
  46                 return 1;
  47         }
  48         return 0;
  49 }