import psycopg2import timeimport selectconn = psycopg2.connect(database="postgres", user="postgres", password="postgres", host="/data01/pgdata/pg_root", port="1921", async=True)>>> def wait(conn):...     while 1:...         state = conn.poll()...         if state == psycopg2.extensions.POLL_OK:...             break...         elif state == psycopg2.extensions.POLL_WRITE:...             select.select([], [conn.fileno()], [])...         elif state == psycopg2.extensions.POLL_READ:...             select.select([conn.fileno()], [], [])...         else:...             raise psycopg2.OperationalError("poll() returned %s" % state)... wait(conn)curs = conn.cursor()curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": 1})curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": 1})Traceback (most recent call last):  File "
      
       ", line 1, in 
       
        psycopg2.ProgrammingError: execute cannot be used while an asynchronous query is underway>>> wait(curs.connection)>>> wait(curs.connection)>>> curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": 1})>>> wait(curs.connection)>>> curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": 1})>>> wait(curs.connection)>>> conn.poll()0>>> curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": 1})>>> conn.poll()0>>> curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": 1})>>> conn.poll()0>>> psycopg2.extensions.POLL_OK0>>> psycopg2.extensions.POLL_WRITE2>>> psycopg2.extensions.POLL_READ1
       
      

>>> curs.prepare("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')")Traceback (most recent call last):  File "
      
       ", line 1, in 
       
        AttributeError: 'psycopg2._psycopg.cursor' object has no attribute 'prepare'>>> dir(curs)['__class__', '__delattr__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__iter__', '__le__', '__lt__', '__ne__', '__new__', '__next__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', 'arraysize', 'binary_types', 'callproc', 'cast', 'close', 'closed', 'connection', 'copy_expert', 'copy_from', 'copy_to', 'description', 'execute', 'executemany', 'fetchall', 'fetchmany', 'fetchone', 'itersize', 'lastrowid', 'mogrify', 'name', 'nextset', 'query', 'row_factory', 'rowcount', 'rownumber', 'scroll', 'scrollable', 'setinputsizes', 'setoutputsize', 'statusmessage', 'string_types', 'typecaster', 'tzinfo_factory', 'withhold']
       
      

2015-02-05 22:37:32.901 CST,"postgres","postgres",69785,"[local]",54d37ee8.11099,1,"idle",2015-02-05 22:32:08 CST,3/1996971,0,LOG,00000,"statement: insert into tt values(1, 'digoal.zhou', 32, 'digoal@126.com', '276732431')",,,,,,,,"exec_simple_query, postgres.c:890",""

>>> curs.execute("prepare pre1(int) as insert into tt values($1, 'digoal.zhou', 32, 'digoal@126.com', '276732431')")>>> conn.poll()0>>> curs.execute("execute pre1(1)")>>> conn.poll()0>>> curs.execute("execute pre1(1)")>>> conn.poll()0

2015-02-05 22:50:42.678 CST,"postgres","postgres",69785,"[local]",54d37ee8.11099,5,"idle",2015-02-05 22:32:08 CST,3/1996975,0,LOG,00000,"statement: prepare pre1(int) as insert into tt values($1, 'digoal.zhou', 32, 'digoal@126.com', '276732431')",,,,,,,,"exec_simple_query, postgres.c:890",""2015-02-05 22:50:59.425 CST,"postgres","postgres",69785,"[local]",54d37ee8.11099,6,"idle",2015-02-05 22:32:08 CST,3/1996976,0,LOG,00000,"statement: execute pre1(1)","prepare: prepare pre1(int) as insert into tt values($1, 'digoal.zhou', 32, 'digoal@126.com', '276732431')",,,,,,,"exec_simple_query, postgres.c:890",""2015-02-05 22:51:22.425 CST,"postgres","postgres",69785,"[local]",54d37ee8.11099,7,"idle",2015-02-05 22:32:08 CST,3/1996977,0,LOG,00000,"statement: execute pre1(1)","prepare: prepare pre1(int) as insert into tt values($1, 'digoal.zhou', 32, 'digoal@126.com', '276732431')",,,,,,,"exec_simple_query, postgres.c:890",""

[root@localhost ~]# cat t.pyimport psycopg2import timeimport threadingclass n_t(threading.Thread):   #The timer class is derived from the class threading.Thread  def __init__(self, num):    threading.Thread.__init__(self)    self.thread_num = num  def run(self): #Overwrite run() method, put what you want the thread do here    conn = psycopg2.connect(database="postgres", user="postgres", password="postgres", host="/data01/pgdata/pg_root", port="1921")    curs = conn.cursor()    conn.autocommit=True    start_t = time.time()    print("TID:" + str(self.thread_num) + " " + str(start_t))    for i in range(self.thread_num*125000, (self.thread_num+1)*125000):      curs.execute("insert into tt values(%(id)s, 'digoal.zhou', 32, 'digoal@126.com', '276732431')", {"id": i})    stop_t = time.time()    print("TID:" + str(self.thread_num) + " " + str(stop_t))    print(stop_t-start_t)def test():  t_names = dict()  for i in range(0,8):    t_names[i] = n_t(i)     t_names[i].start()  returnif __name__ == '__main__':  test()

[root@localhost ~]# python t.pyTID:0 1423148404.5820847TID:1 1423148404.5828164TID:2 1423148404.5850544TID:3 1423148404.58532TID:4 1423148404.5861893TID:5 1423148404.5867805TID:6 1423148404.5882406TID:7 1423148404.588671TID:2 1423148445.14644940.561394691467285TID:7 1423148445.205186140.616515159606934TID:6 1423148445.232101240.64386057853699TID:1 1423148445.26323640.68041968345642TID:5 1423148445.270324240.68354368209839TID:0 1423148445.296777540.71469283103943TID:3 1423148445.306561740.72124171257019TID:4 1423148445.334591640.74840235710144postgres=# select count(*),count(distinct id) from tt;  count  |  count  ---------+--------- 1000000 | 1000000(1 row)