2

私は2つの2つのデータベースを持っています。1 つは MSSQL を使用し、もう 1 つは Postgresql を使用します。Python スクリプトを毎日実行したい (これには、Linux で cron ジョブを使用します)。MSSQL データベースのデータを Postgresql データベースにコピーする必要があります。アイデアはありますが、うまくいきません。私たちを手伝ってくれますか？？？たぶん私の解決策は完全に間違っています...

それが私のコードです：

import pymssql, psycopg2

class DatabaseRequest:

    def __init__(self):
        self.conn1 = pymssql.connect(host='****', user='****', password='****', database='****')
        self.conn2 = psycopg2.connect("dbname='****' user='****' host='*****' password='****'")

        self.cur1 = self.conn1.cursor()
        self.cur2 = self.conn2.cursor()

    def request_proc(self, rows):
        self.cur1.execute("SELECT top 10  tag, site, plant, unit, line, ProcessID AS pid, Count(ReadTime) AS mods \
                        FROM ( \
                        select dateadd(dd, -1, convert(varchar, getDate(),111)) \
                        as tag, ReadTime, processID, subid, PR.Site, PR.Plant, PR.Unit, PR.Line \
                        from FactBarcodeReading BCR with(nolock) \
                        inner join DimProcess PR on BCR.ProcessKey = PR.ProcessKey \
                        where PR.ProcessID IN  (802, 1190, 1800, 3090, 3590, 4390, 4590, 4800, 5000, 5400, 4190) \
                        and ReadTime between dateadd(dd, -1, convert(varchar, getDate(),111)) and dateadd(dd, -0, convert(varchar, getDate(),111)) \
                        ) a \
                        GROUP BY tag, site, plant, unit, line, ProcessID \
                        ORDER BY site, plant, unit, line, ProcessID")

        rows = self.cur1.fetchone()

       # return rows   


    def insert_proc(self):
        self.cur2.execute("INSERT INTO 20091229global (proddate, site, plant, unit, line, pid, mods) \
                        VALUES ('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s')"
                        % self.cur1.fetchone())


        a = DatabaseRequest()
        print a.insert_proc()

PS: request_proc は正常に動作します。

4

3 に答える 3

1

コードでエラーが発生しないが、挿入されたレコードがPostgresqlデータベースに表示されない場合はself.conn2.commit()、INSERTステートメントの実行後に追加する必要があります。これにより、各トランザクションがデータベースにコミットされます。

ドキュメントによると、自動トランザクションを有効にすることも可能です。

于 2011-06-07T16:20:46.597 に答える
0

また、カーソル (cur1) を insert_proc に渡す必要があります -->

def insert_proc(self, cur1):
  self.cur2.execute("INSERT INTO 20091229global (proddate, site, plant, unit, line, pid, mods) \
                        VALUES ('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s')"
                        % self.cur1.fetchone())
于 2018-03-20T14:09:55.660 に答える