Articles of psycopg2

Usando python y postgres, variables dentro de la función de ejecución?

Tuve una pregunta sobre el uso de variables dentro de una función python que accede al servidor PostgreSQL. Por ejemplo, lo siguiente: def delete(): cur.execute( “””DELETE FROM potluck WHERE name = var_1;””” Sin embargo, si quisiera que la función de actualización incorporara variables para var_1, ¿cómo lo haría? Por ejemplo, quiero que mi función esté […]

postgresql: fuera de la memoria compartida?

Estoy ejecutando un montón de consultas usando Python y psycopg2. Creo una gran tabla temporal con aproximadamente 2 millones de filas, luego obtengo 1000 filas a la vez utilizando cur.fetchmany(1000) y ejecuto consultas más extensas relacionadas con esas filas. Sin embargo, las consultas extensas son autosuficientes: una vez que terminan, ya no necesito sus resultados […]

pregunta sobre las variables de enlace postgresql

Estaba mirando la pregunta y decidí intentar usar las variables de enlace. yo suelo sql = ‘insert into abc2 (interfield,textfield) values (%s,%s)’ a = time.time() for i in range(10000): #just a wrapper around cursor.execute db.executeUpdateCommand(sql,(i,’test’)) db.commit() y sql = ‘insert into abc2 (intfield,textfield) values (%(x)s,%(y)s)’ for i in range(10000): db.executeUpdateCommand(sql,{‘x’:i,’y’:’test’}) db.commit() Mirando el tiempo empleado […]

Ejecutar el esquema .sql en psycopg2 en Python

Tengo un esquema PostgreSQL almacenado en un archivo .sql. Se ve algo así como: CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY, facebook_id TEXT NOT NULL, name TEXT NOT NULL, access_token TEXT, created INTEGER NOT NULL ); ¿Cómo debo ejecutar este esquema después de conectarme a la base de datos? Mi código […]

Insertar diccionario de Python usando Psycopg2

¿Cuál es la mejor manera de insertar un diccionario de python con muchas claves en una base de datos de Postgres sin tener que enumerar todas las claves? Me gustaría hacer algo como … song = dict() song[‘title’] = ‘song 1’ song[‘artist’] = ‘artist 1’ … cursor.execute(‘INSERT INTO song_table (song.keys()) VALUES (song)’)

Cómo usar los cursores del lado del servidor con psycopg2

Tengo una tabla con 4 millones de filas y uso psycopg2 para ejecutar un: SELECT * FROM ..WHERE query No he escuchado antes del cursor del lado del servidor y estoy leyendo que es una buena práctica cuando espera muchos resultados. Encuentro la documentación un poco limitada y tengo algunas preguntas básicas. Primero declaro el […]

Copiando datos desde S3 a AWS al redshift usando python y psycopg2

Tengo problemas al ejecutar el comando de copia para cargar datos desde S3 a Redshift de Amazon desde python. Tengo el siguiente comando de copia: copy moves from ‘s3:///moves_data/2013-03-24/18/moves’ credentials ‘aws_access_key_id=;aws_secret_access_key=’ removequotes delimiter ‘,’; Cuando ejecuto este comando usando SQL Workbench / j, todo funciona como se esperaba, sin embargo, cuando bash ejecutar esto con […]

ImportError: error de carga de DLL: al intentar importar la biblioteca psycopg2

>>> importar psycopg2 Rastreo (llamadas recientes más última): Archivo “”, línea 1, en Archivo “C: \ Python26 \ lib \ site-packages \ psycopg2 \ __ init__.py”, línea 60, en desde _psycopg import BINARY, NUMBER, STRING, DATETIME, ROWID ImportError: Error en la carga de DLL: la aplicación no pudo iniciarse debido a que la configuración de […]

Python psycopg2 no se inserta en la tabla postgresql

Estoy usando lo siguiente para intentar insertar un registro en una tabla de base de datos postgresql, pero no funciona. No recibo ningún error, pero no hay registros en la tabla. ¿Necesito un commit o algo? Estoy utilizando la base de datos postgresql que se instaló con la instalación de djangostack de Bitnami. import psycopg2 […]

Crear una base de datos Postgres usando python

Quiero crear la base de datos Postgres usando Python. con = psql.connect(dbname=’postgres’, user=self.user_name, host=”, password=self.password) cur = con.cursor() cur.execute(“CREATE DATABASE %s ;” % self.db_name) Estoy teniendo el siguiente error: InternalError: CREATE DATABASE cannot run inside a transaction block Estoy usando psycopg2 para conectar. No entiendo cuál es el problema. Lo que estoy tratando de hacer […]