CREATE INDEX dtidx ON table (id, created DESC);
async def user_exists(user_id):
conn = await asyncpg.connect(host=host, user=user, password=password, database=database)
try: return await conn.fetchrow(f"SELECT 1 FROM users WHERE (user_id=} LIMIT 1")
finally: await conn.close()
import psycopg2
E = lambda field: f'$myseckey${field}$myseckey$' if type(field) is str else field
with connection.cursor() as cursor:
cursor.execute(
f"""INSERT INTO data(photo_avatar,
name,
type,
reach,
engagemant_er,
engage_percent)
VALUES ({E(profile_name)}, 'N\A', {E(reach)}, {E(engagement)}, {E(engage_per));"""
)
connection.commit()