/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/***************************************************************************
 *            database.cc
 *
 *  Thu Sep  6 10:59:07 CEST 2007
 *  Copyright 2007 Bent Bisballe Nyeng, Lars Bisballe Jensen and Peter Skaarup
 *  deva@aasimon.org, elsenator@gmail.com and piparum@piparum.dk
 ****************************************************************************/

/*
 *  This file is part of Pracro.
 *
 *  Pracro is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  Pracro is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with Pracro; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA.
 */
#include "database.h"

#include "tostring.h"
#include <time.h>
#include <sys/types.h>
#include <unistd.h>

Database::Database(std::string hostname, std::string user, std::string password)
  : c("host=" + hostname +
      " user=" + user +
      " password=" + password +
      " dbname=pracro")
{
  /*
	try {
		char port_string[32];
		sprintf(port_string, "%d", port);
		std::string hoststring = "host=" + host + " port=" + port_string +
      " user=" + user + " password=" + password + " dbname=" + database;
		c = new pqxx::connection(hoststring);

	}	catch(const std::exception &e) {
		//throw PostgreSQLException(e.what());
	}
  */
}

Database::~Database()
{
}

int Database::post(Transaction &transaction)
{
  time_t now = time(NULL);
  std::string transidbase = toString((unsigned int)now) + "-"
    + toString((unsigned int)getpid()) + "-"; // Here we put the commit index

	try {
		pqxx::work W(c);

    Commits::iterator i = transaction.commits.begin();
    unsigned int idx = 0;
    while(i != transaction.commits.end()) {
      Commit &commit = *i;
      std::string transid = transidbase + toString(idx);

      // Insert transaction entry
      std::string sql = "INSERT INTO transactions VALUES('" + 
        transaction.cpr + "', '" + 
        transid + "', '" + 
        commit.macro + "', '" + 
        commit.version + "', '" + 
        toString((unsigned int)now) + "', '" + 
        commit.user + "')";
      W.exec(sql);

      // Insert field entries
      Fields::iterator j = commit.fields.begin();
      while(j != commit.fields.end()) {
        Field &field = *j;

        sql = "INSERT INTO fields VALUES('" + 
          transid + "', '" + 
          field.name + "', '" + 
          field.value + "')";
        W.exec(sql);

        j++;
      }

      idx++;
      i++;
    }

		W.commit();
	}	catch(const std::exception &e) {
    //		throw PostgreSQLException(e.what());
	}

	return 0;
}

// som root
// # createuser -P -h localhost -U postgres
// # createdb -U postgres -h localhost pracro

/*
CREATE DATABASE pracro
  WITH OWNER = pracro
       ENCODING = 'UNICODE'
       TABLESPACE = pg_default;

CREATE TABLE transactions
(
  "cpr" varchar(255),
  "transaction" varchar(255),
  "makro" varchar(255),
  "version" varchar(255),
  "timestamp" varchar(255),
  "user" varchar(255)
) 
WITH OIDS;
ALTER TABLE transactions OWNER TO pracro;

CREATE TABLE fields
(
  "transaction" varchar(255),
  "name" varchar(255),
  "value" varchar(255)
) 
WITH OIDS;
ALTER TABLE fields OWNER TO pracro;

// Get all matching fields
SELECT transactions.timestamp, transactions.transaction, fields.name, fields.value
  FROM transactions, fields
  WHERE transactions.cpr='2003791613'
  AND transactions.transaction=fields.transaction
  AND fields.name='fisk';
*/

/*
  Employees:
  Employee_ID 	Name
  01            Hansen, Ola
  02            Svendson, Tove
  03            Svendson, Stephen
  04            Pettersen, Kari

  Orders:
  Prod_ID 	Product 	Employee_ID
  234       Printer   01
  657       Table     03
  865       Chair     03

  SELECT Employees.Name, Orders.Product
  FROM Employees, Orders
  WHERE Employees.Employee_ID=Orders.Employee_ID
*/