The following works fine: conn = psycopg.connect(self.conn.params.conn_str) cur = conn.cursor() cur.execute(""" SELECT 2, %s; """, (1,), ) But inside a DO: cur.execute(""" DO $$ BEGIN SELECT 2, %s; END$$; """, (1,), ) it causes psycopg.errors.UndefinedParameter: there is no parameter $1…
I'm resurrecting my local environment for a Django project that I haven't run locally in 2 years, working through issues around things that have gone stale. But I have one a little different: it looks like Django is finding/using an…
def update_database(self, results): try: length = len(self.unique_ids) update_data = [(self.unique_ids[i], results[i]) for i in range(length)] query = """ UPDATE public.post_data AS p SET content = t.content FROM (VALUES %s) AS t (unique_id, content) WHERE p.unique_id = t.unique_id; """ template =…
I have the following code: query = "SELECT * FROM appointments WHERE service IN %s AND location LIKE '%London%'" values = (services,) # services is a tuple of strings. cur.execute(query, values) When I execute this code I get the following…
I'm trying to attach a db to my python API. I use Windows 11, docker-compose, fastAPI. Not sure what is missing. In the logs I see the following: docker-compose logs -f time="2024-05-17T16:01:30+04:00" level=warning msg="\code\docker-compose.yml: `version` is obsolete" postgres-1 | postgres-1…
I've got a database table in a Postgres 15 database, it's got two columns (amongst others), one is of type daterange, the other is tstzrange. We've got some code that inserts to this table with raw SQL (via sqlalchemy core)…
Let's suppose we have two queries (I use postgresSQL with psycopg2): 1 - query= """ SELECT * FROM same_table """ 2 - query= """ SELECT * FROM same_table WHERE id = %(some_id)s """ Is it possible to crate a single…
I have issue with connecting to airflow database I can do it locally with such code import pandas as pd from sqlalchemy import create_engine import os df = pd.read_csv('wynik_zgloszenia.csv', sep = '#') engine = create_engine(f'postgresql+psycopg2://postgres:mysecretpassword@localhost:8001/postgres',client_encoding='utf8') df.to_sql('permissions', engine, index=False, if_exists='replace') I…
I am trying to makemigrations in my project with Django using postgresql. But I have been having the following error: (agenda_api) C:UsersfelipOneDriveEscritorioManagmentCursosDjangoagendadjagenda>python manage.py makemigrations Traceback (most recent call last): File "C:UsersfelipOneDriveEscritorioManagmentCursosDjangoagenda_apilibsite-packagesdjangodbbackendspostgresqlbase.py", line 25, in <module> import psycopg2 as Database File…
I used to use execute_values in psycopg2 but it's gone in psycopg3. I tried following the advice in this answer or this github post, but it just doesn't seem to work for my use case. I'm trying to insert multiple…