diff --git a/examples/binary.py b/examples/binary.py index 35b6327b..eaa8f1e7 100644 --- a/examples/binary.py +++ b/examples/binary.py @@ -19,13 +19,13 @@ DSN = 'dbname=test' ## don't modify anything below tis line (except for experimenting) import sys -import psycopg +import psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding curs = conn.cursor() @@ -41,7 +41,7 @@ conn.commit() # using a buffer on a file object. data1 = {'id':1, 'name':'somehackers.jpg', - 'img':psycopg.Binary(open('somehackers.jpg').read())} + 'img':psycopg2.Binary(open('somehackers.jpg').read())} data2 = {'id':2, 'name':'whereareyou.jpg', 'img':buffer(open('whereareyou.jpg').read())} diff --git a/examples/copy_from.py b/examples/copy_from.py index 125be7c9..edd32948 100644 --- a/examples/copy_from.py +++ b/examples/copy_from.py @@ -23,13 +23,13 @@ DSN = 'dbname=test' import sys import os import StringIO -import psycopg +import psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding curs = conn.cursor() diff --git a/examples/copy_to.py b/examples/copy_to.py index 2eea672f..5570fbc4 100644 --- a/examples/copy_to.py +++ b/examples/copy_to.py @@ -23,13 +23,13 @@ DSN = 'dbname=test' import sys import os import StringIO -import psycopg +import psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding curs = conn.cursor() diff --git a/examples/cursor.py b/examples/cursor.py index 607ce189..54cb5e7d 100644 --- a/examples/cursor.py +++ b/examples/cursor.py @@ -19,22 +19,22 @@ DSN = 'dbname=test' ## don't modify anything below this line (except for experimenting) import sys -import psycopg -import psycopg.extensions +import psycopg2 +import psycopg2.extensions if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dsn:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding -class NoDataError(psycopg.ProgrammingError): +class NoDataError(psycopg2.ProgrammingError): """Exception that will be raised by our cursor.""" pass -class Cursor(psycopg.extensions.cursor): +class Cursor(psycopg2.extensions.cursor): """A custom cursor.""" def fetchone(self): @@ -45,7 +45,7 @@ class Cursor(psycopg.extensions.cursor): uses the same function to fetch rows, the code path from Python is different. """ - d = psycopg.extensions.cursor.fetchone(self) + d = psycopg2.extensions.cursor.fetchone(self) if d is None: raise NoDataError("no more data") return d diff --git a/examples/dialtone.py b/examples/dialtone.py index 1203a2c7..f1469a09 100644 --- a/examples/dialtone.py +++ b/examples/dialtone.py @@ -14,8 +14,8 @@ intrusive for your classes (don't want inheritance from an 'Item' or from datetime import datetime -import psycopg -from psycopg.extensions import adapt, register_adapter +import psycopg2 +from psycopg2.extensions import adapt, register_adapter try: sorted() except NameError: diff --git a/examples/dict.py b/examples/dict.py index 37fb0713..37dc74a8 100644 --- a/examples/dict.py +++ b/examples/dict.py @@ -19,18 +19,18 @@ DSN = 'dbname=test' ## don't modify anything below this line (except for experimenting) import sys -import psycopg -import psycopg.extras +import psycopg2 +import psycopg2.extras if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dsn:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding -curs = conn.cursor(cursor_factory=psycopg.extras.DictCursor) +curs = conn.cursor(cursor_factory=psycopg2.extras.DictCursor) curs.execute("SELECT 1 AS foo, 'cip' AS bar, date(now()) as zot") data = curs.fetchone() diff --git a/examples/dt.py b/examples/dt.py index f285c7a1..78d53556 100644 --- a/examples/dt.py +++ b/examples/dt.py @@ -18,7 +18,7 @@ DSN = 'dbname=test' ## don't modify anything below tis line (except for experimenting) -import sys, psycopg +import sys, psycopg2 import mx.DateTime import datetime @@ -26,7 +26,7 @@ if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) curs = conn.cursor() try: diff --git a/examples/encoding.py b/examples/encoding.py index 15062520..d29a0503 100644 --- a/examples/encoding.py +++ b/examples/encoding.py @@ -19,63 +19,63 @@ DSN = 'dbname=test' ## don't modify anything below this line (except for experimenting) -import sys, psycopg +import sys, psycopg2 import psycopg.extensions if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Initial encoding for this connection is", conn.encoding print "\n** This example is supposed to be run in a UNICODE terminal! **\n" print "Available encodings:" -for a, b in psycopg.extensions.encodings.items(): +for a, b in psycopg2.extensions.encodings.items(): print " ", a, "<->", b print "Using STRING typecaster" print "Setting backend encoding to LATIN1 and executing queries:" conn.set_client_encoding('LATIN1') curs = conn.cursor() -curs.execute("SELECT %s::TEXT AS foo", ('àèìòù',)) +curs.execute("SELECT %s::TEXT AS foo", ('�����',)) x = curs.fetchone()[0] print " ->", unicode(x, 'latin-1').encode('utf-8'), type(x) -curs.execute("SELECT %s::TEXT AS foo", (u'àèìòù',)) +curs.execute("SELECT %s::TEXT AS foo", (u'�����',)) x = curs.fetchone()[0] print " ->", unicode(x, 'latin-1').encode('utf-8'), type(x) print "Setting backend encoding to UTF8 and executing queries:" conn.set_client_encoding('UNICODE') curs = conn.cursor() -curs.execute("SELECT %s::TEXT AS foo", (u'àèìòù'.encode('utf-8'),)) +curs.execute("SELECT %s::TEXT AS foo", (u'�����'.encode('utf-8'),)) x = curs.fetchone()[0] print " ->", x, type(x) -curs.execute("SELECT %s::TEXT AS foo", (u'àèìòù',)) +curs.execute("SELECT %s::TEXT AS foo", (u'�����',)) x = curs.fetchone()[0] print " ->", x, type(x) print "Using UNICODE typecaster" -psycopg.extensions.register_type(psycopg.extensions.UNICODE) +psycopg2.extensions.register_type(psycopg2.extensions.UNICODE) print "Setting backend encoding to LATIN1 and executing queries:" conn.set_client_encoding('LATIN1') curs = conn.cursor() -curs.execute("SELECT %s::TEXT AS foo", ('àèìòù',)) +curs.execute("SELECT %s::TEXT AS foo", ('�����',)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) -curs.execute("SELECT %s::TEXT AS foo", (u'àèìòù',)) +curs.execute("SELECT %s::TEXT AS foo", (u'�����',)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) print "Setting backend encoding to UTF8 and executing queries:" conn.set_client_encoding('UNICODE') curs = conn.cursor() -curs.execute("SELECT %s::TEXT AS foo", (u'àèìòù'.encode('utf-8'),)) +curs.execute("SELECT %s::TEXT AS foo", (u'�����'.encode('utf-8'),)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) -curs.execute("SELECT %s::TEXT AS foo", (u'àèìòù',)) +curs.execute("SELECT %s::TEXT AS foo", (u'�����',)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) @@ -84,19 +84,19 @@ print "Executing full UNICODE queries" print "Setting backend encoding to LATIN1 and executing queries:" conn.set_client_encoding('LATIN1') curs = conn.cursor() -curs.execute(u"SELECT %s::TEXT AS foo", ('àèìòù',)) +curs.execute(u"SELECT %s::TEXT AS foo", ('�����',)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) -curs.execute(u"SELECT %s::TEXT AS foo", (u'àèìòù',)) +curs.execute(u"SELECT %s::TEXT AS foo", (u'�����',)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) print "Setting backend encoding to UTF8 and executing queries:" conn.set_client_encoding('UNICODE') curs = conn.cursor() -curs.execute(u"SELECT %s::TEXT AS foo", (u'àèìòù'.encode('utf-8'),)) +curs.execute(u"SELECT %s::TEXT AS foo", (u'�����'.encode('utf-8'),)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) -curs.execute(u"SELECT %s::TEXT AS foo", (u'àèìòù',)) +curs.execute(u"SELECT %s::TEXT AS foo", (u'�����',)) x = curs.fetchone()[0] print " ->", x.encode('utf-8'), ":", type(x) diff --git a/examples/fetch.py b/examples/fetch.py index e0a5728f..e80859bc 100644 --- a/examples/fetch.py +++ b/examples/fetch.py @@ -20,13 +20,13 @@ DSN = 'dbname=test' ## don't modify anything below tis line (except for experimenting) import sys -import psycopg +import psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding curs = conn.cursor() diff --git a/examples/lastrowid.py b/examples/lastrowid.py index 4b01c85f..205ef6ce 100644 --- a/examples/lastrowid.py +++ b/examples/lastrowid.py @@ -18,13 +18,13 @@ DSN = 'dbname=test' ## don't modify anything below tis line (except for experimenting) -import sys, psycopg +import sys, psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) curs = conn.cursor() try: diff --git a/examples/mogrify.py b/examples/mogrify.py index d66e13d1..480c4919 100644 --- a/examples/mogrify.py +++ b/examples/mogrify.py @@ -19,14 +19,14 @@ DSN = 'dbname=test' ## don't modify anything below this line (except for experimenting) -import sys, psycopg +import sys, psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding curs = conn.cursor() @@ -34,14 +34,14 @@ curs.execute("SELECT %(foo)s AS foo", {'foo':'bar'}) curs.execute("SELECT %(foo)s AS foo", {'foo':None}) curs.execute("SELECT %(foo)s AS foo", {'foo':True}) curs.execute("SELECT %(foo)s AS foo", {'foo':42}) -curs.execute("SELECT %(foo)s AS foo", {'foo':u'yattà!'}) +curs.execute("SELECT %(foo)s AS foo", {'foo':u'yatt�!'}) curs.execute("SELECT %(foo)s AS foo", {'foo':u'bar'}) print curs.mogrify("SELECT %(foo)s AS foo", {'foo':'bar'}) print curs.mogrify("SELECT %(foo)s AS foo", {'foo':None}) print curs.mogrify("SELECT %(foo)s AS foo", {'foo':True}) print curs.mogrify("SELECT %(foo)s AS foo", {'foo':42}) -print curs.mogrify("SELECT %(foo)s AS foo", {'foo':u'yattà!'}) +print curs.mogrify("SELECT %(foo)s AS foo", {'foo':u'yatt�!'}) print curs.mogrify("SELECT %(foo)s AS foo", {'foo':u'bar'}) conn.rollback() diff --git a/examples/myfirstrecipe.py b/examples/myfirstrecipe.py index a75a192c..4ddc65e2 100644 --- a/examples/myfirstrecipe.py +++ b/examples/myfirstrecipe.py @@ -66,10 +66,10 @@ and on the psycopg 2 wiki: """ -import psycopg -import psycopg.extensions -from psycopg.extensions import adapt as psycoadapt -from psycopg.extensions import register_adapter +import psycopg2 +import psycopg2.extensions +from psycopg2.extensions import adapt as psycoadapt +from psycopg2.extensions import register_adapter class AsIs(object): """An adapter that just return the object 'as is'. diff --git a/examples/simple.py b/examples/simple.py index 08a36070..faad65b5 100644 --- a/examples/simple.py +++ b/examples/simple.py @@ -23,13 +23,13 @@ class SimpleQuoter(object): def sqlquote(x=None): return "'bar'" -import sys, psycopg +import sys, psycopg2 if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Encoding for this connection is", conn.encoding curs = conn.cursor() diff --git a/examples/threads.py b/examples/threads.py index d4b4fb2b..9e3ea82d 100644 --- a/examples/threads.py +++ b/examples/threads.py @@ -36,7 +36,7 @@ MODE = 1 ## don't modify anything below tis line (except for experimenting) -import sys, psycopg, threading +import sys, psycopg2, threading from psycopg.pool import ThreadedConnectionPool if len(sys.argv) > 1: @@ -45,7 +45,7 @@ if len(sys.argv) > 2: MODE = int(sys.argv[2]) print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) curs = conn.cursor() try: @@ -83,7 +83,7 @@ def insert_func(conn_or_pool, rows): try: c.execute("INSERT INTO test_threads VALUES (%s, %s, %s)", (str(i), i, float(i))) - except psycopg.ProgrammingError, err: + except psycopg2.ProgrammingError, err: print name, ": an error occurred; skipping this insert" print err conn.commit() @@ -112,14 +112,14 @@ def select_func(conn_or_pool, z): conn_or_pool.putconn(conn) s = name + ": number of rows fetched: " + str(len(l)) print s - except psycopg.ProgrammingError, err: + except psycopg2.ProgrammingError, err: print name, ": an error occurred; skipping this select" print err ## create the connection pool or the connections if MODE == 0: - conn_insert = psycopg.connect(DSN) - conn_select = psycopg.connect(DSN) + conn_insert = psycopg2.connect(DSN) + conn_select = psycopg2.connect(DSN) else: m = len(INSERT_THREADS) + len(SELECT_THREADS) n = m/2 diff --git a/examples/tz.py b/examples/tz.py index ba760f21..0ae9fa36 100644 --- a/examples/tz.py +++ b/examples/tz.py @@ -19,16 +19,17 @@ DSN = 'dbname=test' ## don't modify anything below this line (except for experimenting) -import sys, psycopg +import sys +import psycopg2 import datetime -from psycopg.tz import ZERO, LOCAL, FixedOffsetTimezone +from psycopg2.tz import ZERO, LOCAL, FixedOffsetTimezone if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) curs = conn.cursor() try: diff --git a/examples/usercast.py b/examples/usercast.py index fb30237b..13342db0 100644 --- a/examples/usercast.py +++ b/examples/usercast.py @@ -19,7 +19,7 @@ DSN = 'dbname=test' ## don't modify anything below tis line (except for experimenting) -import sys, psycopg +import sys, psycopg2 import psycopg.extensions import whrandom @@ -27,13 +27,13 @@ import whrandom # because the adapter is meant to be used in SQL IN clauses while we use # tuples to represent points but it works and the example is about Rect, not # "Point" -import psycopg.extras +import psycopg2.extras if len(sys.argv) > 1: DSN = sys.argv[1] print "Opening connection using dns:", DSN -conn = psycopg.connect(DSN) +conn = psycopg2.connect(DSN) print "Initial encoding for this connection is", conn.encoding curs = conn.cursor() @@ -65,7 +65,7 @@ class Rect(object): def __conform__(self, proto): """This is a terrible hack, just ignore proto and return self.""" - if proto == psycopg.extensions.ISQLQuote: + if proto == psycopg2.extensions.ISQLQuote: return self def from_points(self, x0, y0, x1, y1): @@ -100,8 +100,8 @@ boxoid = curs.description[0][1] print "Oid for the box datatype is", boxoid # and build the user cast object -BOX = psycopg.extensions.new_type((boxoid,), "BOX", Rect) -psycopg.extensions.register_type(BOX) +BOX = psycopg2.extensions.new_type((boxoid,), "BOX", Rect) +psycopg2.extensions.register_type(BOX) # now insert 100 random data (2 points and a box in each row) for i in range(100):