from deta_py.deta_base.base import DetaBase

# or async version
from deta_py.deta_base.async_base import AsyncDetaBase

data_key = 'your_data_key_here'
base_name = 'your_base_name_here'

db = DetaBase(data_key, base_name)

items = [
    {'value': 1},
    {'value': 2}
]

# Put the items into the base
processed_items = db.put(*items)
# processed_items == [{'key': '012345678910', 'value': 1}, {'key': '123456789101', 'value': 2}]

item = db.get('key1')
if item is not None:
    print('Retrieved item:', item)
else:
    print('Item not found')

db.delete('key1')

item = {'key3': 'value3', 'value': 1}

# Insert the item into the base
inserted_item = db.insert(item)
if inserted_item is not None:
    print('Inserted item:', inserted_item)
else:
    print('Item with the same key already exists')

key = 'key1'

# Create an update request
operations = ItemUpdate()
operations.set(name='John')
operations.increment(age=1)
operations.append(friends=['Jane'])
operations.delete('hobbies')

# Update the item with the specified key
success = db.update(key, operations)

if success:
    print('Item updated successfully')
else:
    print('Item not found')

# Define a query (example: retrieve items where 'age' is greater than 18)
query = [
    {'age?gt': 18, 'age?lt': 20}, # age > 18 and age < 20
    {'age?gt': 30, 'age?lt': 35}, # or age > 30 and age < 35
]

# Query the base
result = db.query(query)

# Retrieve items and handle pagination if necessary
items = result.items
while result.last:
    result = db.query(query, last=result.last)
    items += result.items