トップに関する質問 Python3 Tkinter データベースにデータを書いてからCSV出力したい。

編集履歴

質問編集履歴

修正

2020/10/08 06:32

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -566,11 +566,7 @@
         print(msg, args)
-        if msg == "DB-CNCT":
-            cnct()
-        elif msg == "DB-INSERT":
+        if msg == "DB-INSERT":
             # データベースとの接続がタイムアウトしていたときのための再接続。

修正

2020/10/08 06:32

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -412,7 +412,7 @@
-# 質問後追記 変更（2020/10/08 14:37）
+# 質問後追記 変更（2020/10/08 14:39）
 ```Python:
@@ -598,7 +598,7 @@
         elif msg == "DB-DISCNCT":
-            discnct(con, cur)
+            break
         else:

修正

2020/10/08 05:39

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -412,7 +412,7 @@
-# 質問後追記 変更（2020/10/08 14:34）
+# 質問後追記 変更（2020/10/08 14:37）
 ```Python:
@@ -602,9 +602,9 @@
         else:
+            break
-           discnct(con, cur)
+    discnct(con, cur)
-           break

修正

2020/10/08 05:37

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -602,7 +602,7 @@
         else:
-            discnct(con, cur)
+           discnct(con, cur)
            break

修正

2020/10/08 05:34

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -448,7 +448,7 @@
         user = "root",
-        password = "sh1n@n0pisql",
+        password = "root",
         db = "testdb",

修正

2020/10/08 05:34

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -412,7 +412,7 @@
-# 質問後追記 変更（2020/10/08 12:58）
+# 質問後追記 変更（2020/10/08 14:34）
 ```Python:
@@ -448,7 +448,7 @@
         user = "root",
-        password = "root",
+        password = "sh1n@n0pisql",
         db = "testdb",
@@ -564,6 +564,8 @@
         msg, args = data.get()
+        print(msg, args)
         if msg == "DB-CNCT":
             cnct()
@@ -600,10 +602,10 @@
         else:
+            discnct(con, cur)
            break
-        time.sleep(0.1)

修正

2020/10/08 05:33

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -412,7 +412,7 @@
-# 質問後追記
+# 質問後追記 変更（2020/10/08 12:58）
 ```Python:
@@ -426,6 +426,8 @@
 import threading
+import time
 import tkinter as tk
@@ -438,8 +440,6 @@
 def cnct():
-    global con, cur
     # データベース接続
     con = pymysql.connect(
@@ -460,11 +460,13 @@
-def discnct():
-    global con, cur
+    return con, cur
+def discnct(con, cur):
     # データベース切断
@@ -476,9 +478,9 @@
-def read_and_csvout():
+def read_and_csvout(cur):
-    global cur, tbl
+    global tbl
     cur.execute("SELECT * FROM " + tbl + ";")
@@ -504,9 +506,9 @@
-def clear():
+def clear(cur):
-    global cur, tbl
+    global tbl
     cur.execute("DELETE FROM " + tbl + ";")
@@ -552,61 +554,55 @@
 def loop(data):
+    con, cur = cnct()
     # キュー監視ループ
     while True:
-        # キューにデータが存在したら、順番通りにデータベースへ保存する
-        while not data.empty():
-            # キューにある先頭データを取り出す
+        # キューにある先頭データを取り出す
-            msg, args = data.get()
+        msg, args = data.get()
-            if msg == "DB-CNCT":
+        if msg == "DB-CNCT":
-                cnct()
+            cnct()
-            elif msg == "DB-INSERT":
+        elif msg == "DB-INSERT":
-                global cur, con
-                # データベースとの接続がタイムアウトしていたときのための再接続。
+            # データベースとの接続がタイムアウトしていたときのための再接続。
-                con.ping(reconnect=True)
+            con.ping(reconnect=True)
-                # tmpにあるデータをデータベースに保存
+            # tmpにあるデータをデータベースに保存
-                cur.execute("INSERT INTO " + tbl + " VALUES(%s,%s,%s);", (args[0], args[1], args[2]))
+            cur.execute("INSERT INTO " + tbl + " VALUES(%s,%s,%s);", (args[0], args[1], args[2]))
-            elif msg == "CSV-OUTPUT":
+        elif msg == "CSV-OUTPUT":
-                global cur, con
-                # データベースとの接続がタイムアウトしていたときのための再接続。
+            # データベースとの接続がタイムアウトしていたときのための再接続。
-                con.ping(reconnect=True)
+            con.ping(reconnect=True)
-                read_and_csvout()
+            read_and_csvout(cur)
-                clear()
+            clear(cur)
-                con.commit()
+            con.commit()
-            elif msg == "DB-COMMIT":
+        elif msg == "DB-COMMIT":
-                global con
-                con.commit()
+            con.commit()
-            elif msg == "DB-DISCNCT":
+        elif msg == "DB-DISCNCT":
-                discnct()
+            discnct(con, cur)
-            else:
+        else:
-               break
+           break
+        time.sleep(0.1)
@@ -666,10 +662,6 @@
-    data.put(("DB-CNCT", None))
     # ボタンバインド
     button1.bind("<ButtonRelease>", pushed1)

追加

2020/10/08 03:59

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -409,3 +409,311 @@
         con.commit()
 ```
+# 質問後追記
+```Python:
+from datetime import datetime
+import csv
+import pymysql
+import queue
+import threading
+import tkinter as tk
+tbl = "testtb"
+tmp = []
+def cnct():
+    global con, cur
+    # データベース接続
+    con = pymysql.connect(
+        host = "localhost",
+        user = "root",
+        password = "root",
+        db = "testdb",
+        charset = "utf8"
+    )
+    cur = con.cursor()
+def discnct():
+    global con, cur
+    # データベース切断
+    cur.close()
+    con.close()
+def read_and_csvout():
+    global cur, tbl
+    cur.execute("SELECT * FROM " + tbl + ";")
+    results = cur.fetchall()
+    lst = []
+    for i in range(len(results)):
+        tmp = results[i]
+        lst.append([ tmp[0], tmp[1], tmp[2] ])
+    with open("/home/pi/デスクトップ/data.csv", "a", newline="") as f:
+        writer = csv.writer(f, lineterminator="\r\n")
+        for i in range(len(lst)):
+            writer.writerow(lst[i])
+def clear():
+    global cur, tbl
+    cur.execute("DELETE FROM " + tbl + ";")
+def pushed1(e):
+    global data
+    # データベース保存用データをキューに格納
+    for i in range(50):
+        data.put(("DB-INSERT", [str(i+1), "ButtonPushed1", ""]))
+    data.put(("DB-COMMIT", None))
+def pushed2(e):
+    global data
+    # データベース保存用データをキューに格納
+    for i in range(50):
+        data.put(("DB-INSERT", [str(i+1), "ButtonPushed2", ""]))
+    data.put(("DB-COMMIT", None))
+    data.put(("CSV-OUTPUT", None))
+def loop(data):
+    # キュー監視ループ
+    while True:
+        # キューにデータが存在したら、順番通りにデータベースへ保存する
+        while not data.empty():
+            # キューにある先頭データを取り出す
+            msg, args = data.get()
+            if msg == "DB-CNCT":
+                cnct()
+            elif msg == "DB-INSERT":
+                global cur, con
+                # データベースとの接続がタイムアウトしていたときのための再接続。
+                con.ping(reconnect=True)
+                # tmpにあるデータをデータベースに保存
+                cur.execute("INSERT INTO " + tbl + " VALUES(%s,%s,%s);", (args[0], args[1], args[2]))
+            elif msg == "CSV-OUTPUT":
+                global cur, con
+                # データベースとの接続がタイムアウトしていたときのための再接続。
+                con.ping(reconnect=True)
+                read_and_csvout()
+                clear()
+                con.commit()
+            elif msg == "DB-COMMIT":
+                global con
+                con.commit()
+            elif msg == "DB-DISCNCT":
+                discnct()
+            else:
+               break
+def close():
+    global data, win, thread
+    data.put(("DB-DISCNCT", None))
+    thread.join()
+    # Tkinterアプリの終了
+    win.destroy()
+if __name__ == "__main__":
+    # データベースに保存するデータ格納用
+    data = queue.Queue()
+    # Tkinter UI
+    win = tk.Tk()
+    # ボタン
+    button1 = tk.Button(win, text="Button1")
+    button1.grid(row=0, column=0, sticky="nsew")
+    button2 = tk.Button(win, text="Button2")
+    button2.grid(row=0, column=1, sticky="nsew")
+    # データベース操作スレッド
+    # ※データベース操作はスレッドセーフではないため、1つのスレッドでのみ操作が可能
+    thread = threading.Thread(target=loop, args=(data, ))
+    thread.start()
+    data.put(("DB-CNCT", None))
+    # ボタンバインド
+    button1.bind("<ButtonRelease>", pushed1)
+    button2.bind("<ButtonRelease>", pushed2)
+    # UIクローズ検知
+    win.protocol("WM_DELETE_WINDOW", close)
+    # イベントループ
+    win.mainloop()
+"""
+MariaDB [testdb]> DESC testtb;
++-------+------+------+-----+---------+-------+
+| Field | Type | Null | Key | Default | Extra |
++-------+------+------+-----+---------+-------+
+| data1 | text | YES  |     | NULL    |       |
+| data2 | text | YES  |     | NULL    |       |
+| data3 | text | YES  |     | NULL    |       |
++-------+------+------+-----+---------+-------+
+3 rows in set (0.00 sec)
+"""
+```

修正

2020/10/08 02:57

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -62,7 +62,7 @@
         user = "root",
-        password = "sh1n@n0pisql",
+        password = "root",
         db = "testdb",

追加

2020/10/08 01:20

投稿

person

スコア224

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -356,6 +356,10 @@
+（グローバル変数で適当なフラグを立てることを考えたのですが、Button1のデータ書き込みが終わったのか、Button2のデータ書き込みが終わったのか、そもそも書き込んでいないのかまではloop()内で区別できないような気がします。変数だけじゃなくコールバック関数などを駆使すればできる？）
 どのようにすれば 50,ButtonPushed2 をデータベースに保存した後でCSV出力をすることが可能でしょうか。
@@ -390,7 +394,7 @@
             cur.execute("INSERT INTO " + tbl + " VALUES(%s,%s,%s);", (tmp[0], tmp[1], tmp[2]))
-            # データの内容を指定して、CSV出力
+            # データの内容を指定して、CSV出力（これは解決策としては×）
             if tmp == ["50", "ButtonPushed2", ""]: