Herramientas de usuario

Herramientas del sitio


informatica:lenguajes_de_programacion:python:python_db_postgresql

Python Conexión Postgresql

Psycopg2

Python : psycopg2 : conexión : ejemplo simple

ejemplo simple:

import psycopg2
 
cnx = psycopg2.connect( user="<usuario>",
                        password="<password>",
                        host="<host>",
                        port="<port>",
                        database="<db>" )
 
print("Informarción PostgreSQL Server:")
print(cnx.get_dsn_parameters(), "\n")

Ejemplo simple con Try Catch:

import psycopg2
 
try:
 
  cnx = psycopg2.connect( user="<usuario>",
                        password="<password>",
                        host="<host>",
                        port="<port>",
                        database="<db>" )
 
  print("Informarción PostgreSQL Server:")
  print(cnx.get_dsn_parameters(), "\n")
 
except:
 
  print("No se pudo conectar")

Python : psycopg2 : fetchone : ejemplo simple

import psycopg2
 
try:
 
  cnx = psycopg2.connect( user="<usuario>",
                        password="<password>",
                        host="<host>",
                        port="<port>",
                        database="<db>" )
 
  print("Informarción PostgreSQL Server:")
  print(cnx.get_dsn_parameters(), "\n")
 
  cur = cnx.cursor()
  cur.execute("SELECT * FROM usuarios")
 
 
  row = cur.fetchone() #<-- FetchOne
  while row is not None:
    print( row )
    row = cur.fetchone()
 
 
except (Exception, psycopg2.DatabaseError) as error:
 
  print(error)
 

Python : psycopg2 : fetchall : ejemplo simple

Python : psycopg2 : ejecutar : ejemplo simple

import psycopg2
 
try:
 
  cnx = psycopg2.connect( user="<usuario>",
                        password="<password>",
                        host="<host>",
                        port="<port>",
                        database="<db>" )
 
  print("Informarción PostgreSQL Server:")
  print(cnx.get_dsn_parameters(), "\n")
 
  cursor = cnx.cursor()
  cursor.execute("insert into usuarios( usuario, password, nombrecompleto) values('ABAN3', 'EBEN', 'ABAN BANBIN')")
 
  cnx.commit()
 
except:
 
  print("No se pudo conectar")

auto-commit:

con.autocommit = TRUE

Store procedure:

Leer tabla

Existen dos formas:

  • cursor.fetchone()
  • cursor.fetchall()
 row = cur.fetchone()
 
  while row is not None:
    print( row[0] )
    row = cur.fetchone()
 

Ejemplos psycopg2

# 1. Instalar librerías
!pip install psycopg2-binary sqlalchemy
 
# 2. Importar librerías
import psycopg2
import pandas as pd
from sqlalchemy import create_engine
 
# 3. Configurar parámetros de conexión
host = 'localhost'
dbname = 'tu_base_de_datos'
user = 'tu_usuario'
password = 'tu_password'
port = '5432'
 
# 4. Crear conexión con SQLAlchemy (recomendado para pandas)
engine = create_engine(f'postgresql://{user}:{password}@{host}:{port}/{dbname}')
 
# 5. Leer datos con pandas
query = "SELECT * FROM tu_tabla LIMIT 10;"
df = pd.read_sql(query, engine)
print(df)

Backups Automáticos:

informatica/lenguajes_de_programacion/python/python_db_postgresql.txt · Última modificación: 2026/04/15 02:03 por admin