206 lines
7.5 KiB
Python
206 lines
7.5 KiB
Python
#!/usr/bin/python
|
|
|
|
#Copyright 2008 Steffen Jobbagy-Felso
|
|
#This program is free software: you can redistribute it and/or modify
|
|
#it under the terms of the GNU Affero General Public License as published by
|
|
#the Free Software Foundation, version 3 of the License.
|
|
#
|
|
#This program 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 Affero General Public License
|
|
#along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
#In the "official" distribution you can find the license in
|
|
#agpl-3.0.txt in the docs folder of the package.
|
|
|
|
import os
|
|
import fpdb_simple
|
|
import FpdbSQLQueries
|
|
|
|
class fpdb_db:
|
|
def __init__(self):
|
|
"""Simple constructor, doesnt really do anything"""
|
|
self.db=None
|
|
self.cursor=None
|
|
self.sql = {}
|
|
self.MYSQL_INNODB=2
|
|
self.PGSQL=3
|
|
self.SQLITE=4
|
|
#end def __init__
|
|
|
|
def connect(self, backend, host, database, user, password):
|
|
"""Connects a database with the given parameters"""
|
|
self.backend=backend
|
|
self.host=host
|
|
self.database=database
|
|
self.user=user
|
|
self.password=password
|
|
if backend==self.MYSQL_INNODB:
|
|
import MySQLdb
|
|
self.db=MySQLdb.connect(host = host, user = user, passwd = password, db = database)
|
|
elif backend==self.PGSQL:
|
|
import psycopg2
|
|
self.db = psycopg2.connect(host = host, user = user, password = password, database = database)
|
|
else:
|
|
raise fpdb_simple.FpdbError("unrecognised database backend:"+backend)
|
|
self.cursor=self.db.cursor()
|
|
# Set up query dictionary as early in the connection process as we can.
|
|
self.sql = FpdbSQLQueries.FpdbSQLQueries(self.get_backend_name())
|
|
self.wrongDbVersion=False
|
|
try:
|
|
self.cursor.execute("SELECT * FROM Settings")
|
|
settings=self.cursor.fetchone()
|
|
if settings[0]!=118:
|
|
print "outdated or too new database version - please recreate tables"
|
|
self.wrongDbVersion=True
|
|
except:# _mysql_exceptions.ProgrammingError:
|
|
print "failed to read settings table - please recreate tables"
|
|
self.wrongDbVersion=True
|
|
#end def connect
|
|
|
|
def create_table(self, string):
|
|
"""creates a table for the given string
|
|
The string should the name of the table followed by the column list
|
|
in brackets as if it were an SQL command. Do NOT include the "CREATE TABLES"
|
|
bit at the beginning nor the ";" or ENGINE= at the end"""
|
|
string="CREATE TABLE "+string
|
|
if (self.backend==self.MYSQL_INNODB):
|
|
string+=" ENGINE=INNODB"
|
|
string+=";"
|
|
#print "create_table, string:", string
|
|
self.cursor.execute(string)
|
|
self.db.commit()
|
|
#end def create_table
|
|
|
|
def disconnect(self, due_to_error=False):
|
|
"""Disconnects the DB"""
|
|
if due_to_error:
|
|
self.db.rollback()
|
|
else:
|
|
self.db.commit()
|
|
self.cursor.close()
|
|
self.db.close()
|
|
#end def disconnect
|
|
|
|
def reconnect(self, due_to_error=False):
|
|
"""Reconnects the DB"""
|
|
#print "started fpdb_db.reconnect"
|
|
self.disconnect(due_to_error)
|
|
self.connect(self.backend, self.host, self.database, self.user, self.password)
|
|
#end def disconnect
|
|
|
|
def drop_tables(self):
|
|
"""Drops the fpdb tables from the current db"""
|
|
oldDbVersion=0
|
|
try:
|
|
self.cursor.execute("SELECT * FROM settings") #for alpha1
|
|
oldDbVersion=self.cursor.fetchone()[0]
|
|
except:# _mysql_exceptions.ProgrammingError:
|
|
pass
|
|
try:
|
|
self.cursor.execute("SELECT * FROM Settings")
|
|
oldDbVersion=self.cursor.fetchone()[0]
|
|
except:# _mysql_exceptions.ProgrammingError:
|
|
pass
|
|
|
|
if oldDbVersion<=34:
|
|
self.cursor.execute("DROP TABLE IF EXISTS settings;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS HudDataHoldemOmaha;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS autorates;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS board_cards;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS hands_actions;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS hands_players;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS hands;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS tourneys_players;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS tourneys;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS players;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS gametypes;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS sites;")
|
|
|
|
if oldDbVersion>34 and oldDbVersion<=45:
|
|
self.cursor.execute("DROP TABLE IF EXISTS HudDataHoldemOmaha;")
|
|
|
|
self.cursor.execute("DROP TABLE IF EXISTS Settings;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS HudCache;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS Autorates;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS BoardCards;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS HandsActions;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS HandsPlayers;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS Hands;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS TourneysPlayers;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS Tourneys;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS Players;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS Gametypes;")
|
|
if oldDbVersion>45 and oldDbVersion<=51:
|
|
self.cursor.execute("DROP TABLE IF EXISTS TourneysGametypes;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS TourneyTypes;")
|
|
self.cursor.execute("DROP TABLE IF EXISTS Sites;")
|
|
|
|
self.db.commit()
|
|
#end def drop_tables
|
|
|
|
def get_backend_name(self):
|
|
"""Returns the name of the currently used backend"""
|
|
if self.backend==2:
|
|
return "MySQL InnoDB"
|
|
elif self.backend==3:
|
|
return "PostgreSQL"
|
|
else:
|
|
raise fpdb_simple.FpdbError("invalid backend")
|
|
#end def get_backend_name
|
|
|
|
def get_db_info(self):
|
|
return (self.host, self.database, self.user, self.password)
|
|
#end def get_db_info
|
|
|
|
def fillDefaultData(self):
|
|
self.cursor.execute("INSERT INTO Settings VALUES (118);")
|
|
self.cursor.execute("INSERT INTO Sites VALUES (DEFAULT, \"Full Tilt Poker\", 'USD');")
|
|
self.cursor.execute("INSERT INTO Sites VALUES (DEFAULT, \"PokerStars\", 'USD');")
|
|
self.cursor.execute("INSERT INTO TourneyTypes VALUES (DEFAULT, 1, 0, 0, 0, False);")
|
|
#end def fillDefaultData
|
|
|
|
def recreate_tables(self):
|
|
"""(Re-)creates the tables of the current DB"""
|
|
|
|
if self.backend == 3:
|
|
# postgresql
|
|
print "recreating tables in postgres db"
|
|
schema_file = open('schema.postgres.sql', 'r')
|
|
schema = schema_file.read()
|
|
schema_file.close()
|
|
curse = self.db.cursor()
|
|
# curse.executemany(schema, [1, 2])
|
|
for sql in schema.split(';'):
|
|
sql = sql.rstrip()
|
|
if sql == '':
|
|
continue
|
|
curse.execute(sql)
|
|
#self.fillDefaultData()
|
|
self.db.commit()
|
|
curse.close()
|
|
return
|
|
|
|
self.drop_tables()
|
|
|
|
self.cursor.execute(self.sql.query['createSettingsTable'])
|
|
self.cursor.execute(self.sql.query['createSitesTable'])
|
|
self.cursor.execute(self.sql.query['createGametypesTable'])
|
|
self.cursor.execute(self.sql.query['createPlayersTable'])
|
|
self.cursor.execute(self.sql.query['createAutoratesTable'])
|
|
self.cursor.execute(self.sql.query['createHandsTable'])
|
|
self.cursor.execute(self.sql.query['createBoardCardsTable'])
|
|
self.cursor.execute(self.sql.query['createTourneyTypesTable'])
|
|
self.cursor.execute(self.sql.query['createTourneysTable'])
|
|
self.cursor.execute(self.sql.query['createTourneysPlayersTable'])
|
|
self.cursor.execute(self.sql.query['createHandsPlayersTable'])
|
|
self.cursor.execute(self.sql.query['createHandsActionsTable'])
|
|
self.cursor.execute(self.sql.query['createHudCacheTable'])
|
|
self.fillDefaultData()
|
|
self.db.commit()
|
|
print "finished recreating tables"
|
|
#end def recreate_tables
|
|
#end class fpdb_db
|