0

我运行循环并在每个循环中集中查询大量数据。我的数据库是使用 Crate 构建的。有时，由于 Crate 没有回复我的查询结果，循环会暂停。（但这并不总是发生）伪代码如下

from crate import client

class data_access(object):
    def __init__(self, IP):
        conn = client.connect(IP)
        self.cursor = conn.cursor()

    def get_report(self, event_id):
        self.cursor.execute('''
            select schema.events."Info", schema.events."Time"
            from schema.events
            where schema.events."Id"='%s' ''' % event_id)

        event = []
        for row in self.cursor:
           event.append((row[0], row[1]))

        return event


dal = data_access("server IP")
all_events = []
for event_id in event_ids:
    events = dal.get_report(event_id)
    if len(events) >0: all_event += events

的长度event_ids可能是数百万，并且在每个循环中查询都是密集的。有没有使用 Crate 的数据库专家遇到过这个问题？如果是，你是如何解决这个问题的？似乎重新启动数据库不起作用。非常感谢您的解决方案！

4

1 回答 1

1

我无法重现这一点，但我怀疑这可能是由于您每次都在循环内创建连接造成的。我不会重新创建连接数百万次，而是将其重写为在循环外创建一次连接，然后将其传递给get_report，例如：

from crate import client

def get_report(event_id, conn):
    cursor = conn.cursor()
    cursor.execute('''
       select schema.events."Info", schema.events."Time"
       from schema.events
       where schema.events."Id"='%s' ''' % event_id)

    event = []
    for row in cursor:
       event.append((row[0], row[1]))

    return event


all_events = []
conn = client.connect("server IP")
for event_id in event_ids:
    events = get_report(event_id, conn)
    if len(events) >0: all_event += events
于 2017-03-28T08:43:11.440 回答