Asyncpg exceptions postgressyntaxerror ошибка синтаксиса примерное положение

In my python code using asyncpg, I am passing in a tuple (‘PENDING’,) into a where-in query, which is logged as:

args=('TYPE_1', ('PENDING',))

query=SELECT * FROM actions where type = $1 AND status IN $2

It seems like the sql query should finally be

SELECT * FROM actions where type = TYPE_1 AND status in ('PENDING',);

but the above code results in:

asyncpg.exceptions.PostgresSyntaxError: syntax error at or near "$2"

I think it probably is because of the trailing comma in the tuple, but I don’t know how to get rid of it..

Я все еще изучаю PostgreSQL. Во время тестирования я использовал оператор INSERT только в psycopg2, а теперь и в asyncpg. Теперь мне нужно ОБНОВЛЯТЬ данные в моей тестовой базе данных вместо того, чтобы заменять их все.

В настоящее время я пытаюсь выполнить простой тест замены в таблице тестирования, прежде чем перейти к таблице разработки с дополнительными данными.

Я хочу заменить любое имя $ 1, находящееся в CONFLICT, на имя, которое уже есть в таблице users. Я пробую код запроса, который передается в БД через asyncpg. Я продолжаю получать синтаксические ошибки, поэтому я немного не понимаю, как исправить эти ошибки.

Каков правильный синтаксис этого запроса?

'''INSERT INTO users(name, dob) 
   VALUES($1, $2)
   ON CONFLICT (name)
   DO 
     UPDATE "users"
     SET name = 'TEST'
     WHERE name = excluded.name '''

Обновлено:

Я получаю это сообщение об ошибке при использовании asyncpg:

asyncpg.exceptions.PostgresSyntaxError: syntax error at or near ""users""

Я получаю это сообщение об ошибке при использовании psycopg2:

psycopg2.ProgrammingError: syntax error at or near ""users""

Это код asyncpg, который я использовал для вставки INSERT:

async def insert_new_records(self, sql_command, data):

    print (sql_command)

    async with asyncpg.create_pool(**DB_CONN_INFO, command_timeout=60) as pool:
        async with pool.acquire() as conn:
            try:
                stmt = await conn.prepare(sql_command)
                async with conn.transaction():
                    for value in data:
                        async for item in stmt.cursor(*value):
                            pass
            finally:
                await pool.release(conn)


test_sql_command = '''
INSERT INTO users(name, dob)
VALUES($1, $2)
ON CONFLICT (name)
DO
  UPDATE "users"
  SET name = 'TEST'
  WHERE name = excluded.name '''

# The name 'HELLO WORLD' exists in the table, but the other name does not.
params = [('HELLO WORLD', datetime.date(1984, 3, 1)),
          ('WORLD HELLO', datetime.date(1984, 3, 1))]

loop = asyncio.get_event_loop()
loop.run_until_complete(db.insert_new_records(test_sql_command, params))

Похожие вопросы