#!/usr/bin/python

import pgdb
import config
from bkmark import Bookmark

class MyDbConnexion:
	def __init__(self):
		self.cnx = pgdb.connect(database = config.database,
			host = config.host+':%d'%config.port,
			user = config.user, password = config.passwd)
		self.crs = self.cnx.cursor();
	def add_bookmark(self, bk):
		id = self.get_next_id('bookmarks')
		self.crs.execute("""
			INSERT INTO bookmarks(id, url, name, ldesc, added)
			VALUES (%d, '%s', '%s', '%s', '%s');
			INSERT INTO bookmarks_keywords(bookmark, keyword)
			VALUES (%d, %d);
			""" % (id, bk.url, bk.name, bk.desc, bk.added,
			id, 0))
		self.cnx.commit()
		return id
	def get_bookmarks(self, ids):
		qry = """
			SELECT id, url, name, ldesc, added
			FROM bookmarks
			WHERE id = %d
			""" % (ids.pop(),)
		for id in ids:
			qry = qry + " OR id = %d" % (id,)
		qry = qry + ";"
		self.crs.execute(qry)
		bks = []
		list = self.crs.fetchall()
		for res in list:
			bk = Bookmark()
			bk.id = res[0]
			bk.url = res[1]
			bk.name = res[2]
			bk.desc = res[3]
			bk.added = res[4]
			bks.append(bk)
		return bks
	def update_bookmark(self, bk):
		self.crs.execute("""
			UPDATE bookmarks
			SET url = '%s', name = '%s',
			ldesc = '%s', added = '%s'
			WHERE id = %d;
			""" % (bk.url, bk.name, bk.desc, bk.added, bk.id))
		self.cnx.commit()
	def update_keywords(self, id, keywords):
		self.crs.execute("""
			DELETE FROM bookmarks_keywords
			WHERE bookmark = %d AND
			keyword <> 0;""" % (id,))
		for kw in keywords:
			if kw == 0: continue
			self.crs.execute("""
				INSERT INTO
				bookmarks_keywords(bookmark, keyword)
				VALUES (%d, %d);""" % (id, kw))
		self.cnx.commit()	
	def remove_bookmark(self, id):
		self.crs.execute("""
			DELETE FROM bookmarks_keywords
			WHERE bookmark = %d;
			DELETE FROM bookmarks
			WHERE id = %d;
			""" % (id, id))
		self.cnx.commit()
	def add_keyword(self, name):
		id = self.get_next_id('keywords')
		self.crs.execute("""
			INSERT INTO keywords(id, name)
			VALUES (%d, '%s')'
			""" % (id, name))
		self.cnx.commit()
		return id
	def get_keyword(self, id):
		self.crs.execute("""
			SELECT name FROM keywords
			WHERE keyword.id = %d;
			""" % (id,))
		return self.crs.fetchone()[0]
	def get_keywords(self, bk_id):
		self.crs.execute("""
			SELECT id, name FROM keywords, bookmarks_keywords
			WHERE keywords.id = bookmarks_keywords.keyword
			AND bookmarks_keywords.bookmark = %d
			ORDER BY id;
			""" % (bk_id,))
		return self.crs.fetchall()
	def update_keyword(self, id, name):
		self.crs.execute("""
			UPDATE keywords
			SET name = '%s'
			WHERE id = %d;
			""" % (name, id))
		self.cnx.commit()
	def remove_keyword(self, id):
		if id == 0:
			raise "Can't remove default keyword!"
		self.crs.execute("""
			DELETE FROM bookmarks_keywords
			WHERE keyword = %d;
			DELETE FROM keywords
			WHERE id = %d;
			""" % (id, id))
		self.cnx.commit()
	def merge_keywords(self, merge_id, into_id):
		self.crs.execute("""
			UPDATE bookmarks_keywords
			SET keyword = %d
			WHERE keyword = %d;
			""" % (into_id, merge_id))
		self.remove_keyword(merge_id)
	def get_all_keywords(self):
		"""Return a list of pair-elements [id, keyword]."""
		self.crs.execute("SELECT id, name FROM keywords ORDER BY id;")
		return self.crs.fetchall()
	def select_bookmarks(self, has_kw = [0], except_kw = []):
	        """
Return a list of id bookmarks who has /has_kw/ set but not /except_kw/.
"""
		basic_qry = """
		  SELECT id FROM bookmarks, bookmarks_keywords
		  WHERE bookmarks.id = bookmarks_keywords.bookmark
		  AND bookmarks_keywords.keyword = %d
		  """
		
		qry = basic_qry % has_kw[0]
		for kw in has_kw[1:]:
			qry = qry + ("INTERSECT " + basic_qry % kw)
		for kw in except_kw:
			qry = qry + ("EXCEPT " + basic_qry % kw)
		qry = qry + ';'
		self.crs.execute(qry)
		return self.crs.fetchall()
	def get_next_id(self, seq_name):
		self.crs.execute("""
			SELECT nextid FROM db_sequence WHERE
			db_sequence.seq_name = '%s' FOR UPDATE;
			""" % (seq_name))
		id = self.crs.fetchone()[0]
		self.crs.execute("""
			UPDATE db_sequence SET nextid = %d
			WHERE seq_name = 'bookmarks';
			""" % (id+1,))
		return id

def connect():
	return MyDbConnexion()