Das deutsche Python-Forum

Code: Alles auswählen

# Datei einlesen
with open (mypdf,"rb") as f:
	filedata = f.read()
	filedata=filedata.encode("base64")


# DB-Verbindung herstellen
conn = initDBConn()
curs = createCursor(conn)


curs.execute("""UPDATE mytable SET pdfdatei=%(bytea)s;""",{'bytea' : psycopg2.Binary(filedata)})
conn.commit()

# DB-Verbindung schließen
closeConnection(conn)

Code: Alles auswählen

from __future__ import with_statement
import sys
import psycopg2
import psycopg2.extensions


def initDBConnection(): 
	dbhost = 'localhost'
	dbname = 'mydb'
	dbport = '5432'
	dbuser = 'myuser'
	dbpass = 'password'

	try:	
		connection = psycopg2.connect("dbname='" + dbname + "' user='" + dbuser + "' host='" + dbhost + "' port='" + dbport + "' password='" + dbpass + "'")
	except psycopg2.Error, e:
		print "Verbindung zur Datenbank konnte mit psycopg2 nicht aufgebaut werden."
		quit(1)
	return connection


def createCursor(connection):													 
	try:	return connection.cursor()
	except psycopg2.Error, e:
		print "Es konnte kein Cursor zur Datenbank gesetzt werden! "
		quit(1)

def closeConnection(connection):													
	connection.close()