remote/sqlite-utils
1
0
Fork 0
mirror of https://github.com/simonw/sqlite-utils.git synced 2026-07-28 20:04:32 +02:00
Code Issues Projects Releases Packages Wiki Activity

Implemented table.lookup(...), closes #44

Browse source 
* Add pk column if missing from insert
* Implemented table.lookup(...)
This commit is contained in:
Simon Willison 2019-07-23 06:06:59 -07:00 • committed by GitHub
commit 5805024316
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 124 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

25
sqlite_utils/db.py
View file

@ -224,6 +224,8 @@ class Database:
single_pk = None
if isinstance(pk, str):
single_pk = pk
if pk not in [c[0] for c in column_items]:
column_items.insert(0, (pk, int))
for column_name, column_type in column_items:
column_extras = []
if column_name == single_pk:
@ -954,6 +956,29 @@ class Table:
if col_name not in current_columns:
self.add_column(col_name, col_type)
def lookup(self, column_values):
# lookups is a dictionary - all columns will be used for a unique index
if self.exists:
self.add_missing_columns([column_values])
# TODO: Ensure we have a unique index on these
unique_column_sets = [set(i.columns) for i in self.indexes]
if set(column_values.keys()) not in unique_column_sets:
self.create_index(column_values.keys(), unique=True)
wheres = ["[{}] = ?".format(column) for column in column_values]
rows = list(
self.rows_where(
" and ".join(wheres), [value for _, value in column_values.items()]
)
)
try:
return rows[0]["id"]
except IndexError:
return self.insert(column_values, pk="id").last_pk
else:
pk = self.insert(column_values, pk="id").last_pk
self.create_index(column_values.keys(), unique=True)
return pk
def chunks(sequence, size):
iterator = iter(sequence)