voussoir/etiquette
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Add PhotoDB.sql_delete.

Browse source
This commit is contained in:
voussoir 2018-02-25 16:09:36 -08:00
parent f6cef5bcbf
commit a2e13003e8
1 changed files with 15 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
etiquette/photodb.py
View file

@ -1326,12 +1326,24 @@ class PhotoDB(PDBAlbumMixin, PDBBookmarkMixin, PDBPhotoMixin, PDBTagMixin, PDBUs
thing = thing_map['class'](self, db_row=thing) thing = thing_map['class'](self, db_row=thing)
yield thing yield thing
def sql_delete(self, table, pairs, *, commit=False):
cur = self.sql.cursor()
(qmarks, bindings) = sqlhelpers.delete_filler(pairs)
query = 'DELETE FROM %s %s' % (table, qmarks)
#self.log.debug(query)
cur.execute(query, bindings)
if commit:
self.commit()
def sql_insert(self, table, data, *, commit=False): def sql_insert(self, table, data, *, commit=False):
column_names = constants.SQL_COLUMNS[table] column_names = constants.SQL_COLUMNS[table]
cur = self.sql.cursor() cur = self.sql.cursor()
(qmarks, bindings) = sqlhelpers.insert_filler(column_names, data) (qmarks, bindings) = sqlhelpers.insert_filler(column_names, data)
query = 'INSERT INTO %s VALUES(%s)' % (table, qmarks) query = 'INSERT INTO %s VALUES(%s)' % (table, qmarks)
#self.log.debug(query)
cur.execute(query, bindings) cur.execute(query, bindings)
if commit: if commit:
@ -1340,8 +1352,9 @@ class PhotoDB(PDBAlbumMixin, PDBBookmarkMixin, PDBPhotoMixin, PDBTagMixin, PDBUs
def sql_update(self, table, pairs, where_key, *, commit=False): def sql_update(self, table, pairs, where_key, *, commit=False):
cur = self.sql.cursor() cur = self.sql.cursor()
(query, bindings) = sqlhelpers.update_filler(pairs, where_key=where_key) (qmarks, bindings) = sqlhelpers.update_filler(pairs, where_key=where_key)
query = 'UPDATE %s %s' % (table, query) query = 'UPDATE %s %s' % (table, qmarks)
#self.log.debug(query)
cur.execute(query, bindings) cur.execute(query, bindings)
if commit: if commit: