現在PythonとSQLite3で、あるCSVファイルを読み込み、DBのテーブルを更新するプログラムを作成しています。
更新前のデータをA、更新後のデータをB、テーブルをhogeとします。
読み込むCSVファイルをBとして、DBの内容をこちらの内容に書き換える時、Aにあるデータ(既存データ)はUPDATE、ないデータはINSERT INTOをする処理として、REPLACE INTO文を用いております。
この時、Aにはあるが、Bにはないデータは削除されないため、この処理を実装して、完全にDBのデータ内容をBのものにしたいと考えております。
下記は作成中のPythonコードを一部抜粋したものです。
Python
1import sqlite3 2import csv 3 4FILE_PATH = 'ファイルパス' 5 6def load_csv_file(csv_file): 7 # CSVファイル読込み 8 with open(FILE_PATH + csv_file, 'r') as f: 9 reader = csv.reader(f) 10 col = next(reader) # 1行目(カラム名) 11 data = [r for r in reader] # 2行目以降(データ内容) 12 13 return data 14 15def update_records(): 16 17 data = load_csv_file('B.csv') 18 19 # DB処理 20 try: 21 record = [] 22 sql = 'REPLACE INTO hoge VALUES (?, ?, ?)' 23 24 for i in range(len(data)): 25 record.append(data[i][0], data[i][1], data[i][2]) 26 27 db_execute_many(sql, record) 28 db_commit() 29 30 except sqlite3.Error as e: 31 print(e) 32 33if __name__ == '__main__': 34 update_records() 35
上記コードでは、INSERTとUPDATEの処理はできるのですが、AにはあるがBにはなくなっているレコードの削除ができないため、どこかにDELETEの処理が必要かと思います。
AにはあってBにはないレコードという処理をSQLでできるのであれば、DELETE文のWHERE句でそれを指定し、REPLACE INTO文の後に、DELETE文を実行すれば良いのかと思うのですが、その方法がわかりません。
方法については特にこだわりはないのですが、できれば効率的な方法をとりたいと思っております。
ご教示の程よろしくお願い致します。