python postgres游标时间戳问题

我对事务数据库有点新,并且遇到了我想要了解的问题.

我创建了一个简单的演示,其中数据库连接存储在cherrypy创建的5个线程中.我有一个方法,显示存储在数据库中的时间戳表和一个添加新的时间戳记记录的按钮.

该表有2个字段,一个用于python传递的datetime.datetime.now()时间戳,另一个用于数据库时间戳设置为默认NOW().

CREATE TABLE test (given_time timestamp,
                   default_time timestamp DEFAULT NOW());

我有2个与数据库交互的方法.第一个将创建一个新游标,插入一个新的given_timestamp,提交游标,然后返回索引页面.第二种方法将创建一个新游标,选择10个最新时间戳并将其返回给调用者.

import sys
import datetime
import psycopg2
import cherrypy

def connect(thread_index): 
    # Create a connection and store it in the current thread 
    cherrypy.thread_data.db = psycopg2.connect('dbname=timestamps')

# Tell CherryPy to call "connect" for each thread, when it starts up
cherrypy.engine.subscribe('start_thread', connect)

class Root:
    @cherrypy.expose
    def index(self): 
        html = []
        html.append("")

        html.append("")
        html.append("")
        html.append("")

        for given, default in self.get_timestamps():
            html.append("")
        html.append("
Given Time
Default Time
%s
%s" % (given, default))

        html.append("
")

        html.append("
")
        html.append("")
        html.append("
")

        html.append("")
        return "\n".join(html)

    @cherrypy.expose
    def add_timestamp(self):
        c = cherrypy.thread_data.db.cursor()
        now = datetime.datetime.now()
        c.execute("insert into test (given_time) values ('%s')" % now)
        c.connection.commit()
        c.close()
        raise cherrypy.HTTPRedirect('/')

    def get_timestamps(self):
        c = cherrypy.thread_data.db.cursor()
        c.execute("select * from test order by given_time desc limit 10")
        records = c.fetchall()
        c.close()
        return records

if __name__ == '__main__':

    cherrypy.config.update({'server.socket_host': '0.0.0.0',
                            'server.socket_port': 8081,
                            'server.thread_pool': 5,
                            'tools.log_headers.on': False,
                            })

    cherrypy.quickstart(Root())

我希望given_time和default_time时间戳只相隔几微秒.但是我得到了一些奇怪的行为.如果我每隔几秒钟添加一次时间戳,则default_time与given_time相差不到几微秒,但通常比之前的 given_time减去几微秒.

Given Time                  Default Time
2009-03-18 09:31:30.725017  2009-03-18 09:31:25.218871
2009-03-18 09:31:25.198022  2009-03-18 09:31:17.642010
2009-03-18 09:31:17.622439  2009-03-18 09:31:08.266720
2009-03-18 09:31:08.246084  2009-03-18 09:31:01.970120
2009-03-18 09:31:01.950780  2009-03-18 09:30:53.571090
2009-03-18 09:30:53.550952  2009-03-18 09:30:47.260795
2009-03-18 09:30:47.239150  2009-03-18 09:30:41.177318
2009-03-18 09:30:41.151950  2009-03-18 09:30:36.005037
2009-03-18 09:30:35.983541  2009-03-18 09:30:31.666679
2009-03-18 09:30:31.649717  2009-03-18 09:30:28.319693

然而,如果我每分钟添加一个新的时间戳,则given_time和default_time都只是按预期的几微秒关闭.但是,在提交第6个时间戳(线程数+ 1)之后,default_time与第一个given_time时间戳相差几微秒.

Given Time                  Default Time
2009-03-18 09:38:15.906788  2009-03-18 09:33:58.839075
2009-03-18 09:37:19.520227  2009-03-18 09:37:19.520293
2009-03-18 09:36:04.744987  2009-03-18 09:36:04.745039
2009-03-18 09:35:05.958962  2009-03-18 09:35:05.959053
2009-03-18 09:34:10.961227  2009-03-18 09:34:10.961298
2009-03-18 09:33:58.822138  2009-03-18 09:33:55.423485

即使我在每次使用后显式关闭游标,看起来前一个游标仍然被重用.如果我在完成光标并每次创建一个新光标后关闭光标,那怎么可能呢？有人可以解释一下这里发生了什么吗？

接近答案:

我已经将一个cursor.connection.commit()添加到了get_timestamps方法,现在它为我提供了带有时间戳的准确数据.任何人都可以解释为什么我需要调用cursor.connection.commit()当我所做的只是一个选择？我猜每次我得到一个游标,一个事务就开始了(或者继续它提交的现有事务单元).有没有更好的方法来做到这一点,或者每次我得到一个光标时,无论我对该光标做什么,我都会坚持提交？