/* -*- 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 "uid.h"

Database::Database(std::string hostname, std::string user, std::string password)
  : c("host=" + hostname +
      " user=" + user +
      " password=" + password +
      " dbname=pracro")
{
}

Database::~Database()
{
}

int Database::post(std::string &user, std::string &cpr, std::string &time, Commit &commit)
{
  UID uid;

	try {
		pqxx::work W(c);

    //      std::string transid = transidbase + toString(idx);

    // Insert transaction entry
    std::string sql = "INSERT INTO transactions VALUES('" + 
      cpr + "', '" + 
      uid.toString() + "', '" + 
      commit.macro + "', '" + 
      commit.version + "', '" + 
      time + "', '" + 
      user + "')";
    W.exec(sql);
    
    // Insert field entries
    Fields::iterator j = commit.fields.begin();
    while(j != commit.fields.end()) {
      //      std::string name = j->first;
      //      std::string value = j->second;

      sql = "INSERT INTO fields VALUES('" + 
        uid.toString() + "', '" + 
        j->first + "', '" + 
        j->second + "')";
      //        name + "', '" + 
      //        value + "')";
      W.exec(sql);
      
      j++;
    }

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

	return 0;
}
/*
int Database::getTransaction(cpr, transid)
{
  SELECT fields.name, fields.value
    FROM transactions, fields
    WHERE transactions.cpr='2003791613'
    AND transactions.transaction='1234567890'
    AND transactions.transaction=fields.transaction
}
*/

/*
int Database::getMakro(cpr, macro)
{
  SELECT fields.name, fields.value
    FROM transactions, fields
    WHERE transactions.cpr='2003791613'
    AND transactions.macro='dims'
    AND transactions.transaction=fields.transaction
}
*/

// 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(11),
  "transaction" text,
  "makro" text,
  "version" text,
  "timestamp" bigint,
  "user" text
) 
WITH OIDS;
ALTER TABLE transactions OWNER TO pracro;

CREATE TABLE fields
(
  "transaction" text,
  "name" text,
  "value" text
) 
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
*/