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

編集履歴

質問編集履歴

修正

2020/10/08 06:32

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -282,9 +282,7 @@
         # キューにある先頭データを取り出す
         msg, args = data.get()
         print(msg, args)
-        if msg == "DB-CNCT":
-            cnct()
-        elif msg == "DB-INSERT":
+        if msg == "DB-INSERT":
             # データベースとの接続がタイムアウトしていたときのための再接続。
             con.ping(reconnect=True)
             # tmpにあるデータをデータベースに保存

修正

2020/10/08 06:32

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -205,7 +205,7 @@
         con.commit()
 ```
-# 質問後追記 変更（2020/10/08 14:37）
+# 質問後追記 変更（2020/10/08 14:39）
 ```Python:
 from datetime import datetime
 import csv
@@ -298,7 +298,7 @@
         elif msg == "DB-COMMIT":
             con.commit()
         elif msg == "DB-DISCNCT":
-            discnct(con, cur)
+            break
         else:
             break
     discnct(con, cur)

修正

2020/10/08 05:39

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -205,7 +205,7 @@
         con.commit()
 ```
-# 質問後追記 変更（2020/10/08 14:34）
+# 質問後追記 変更（2020/10/08 14:37）
 ```Python:
 from datetime import datetime
 import csv
@@ -300,8 +300,8 @@
         elif msg == "DB-DISCNCT":
             discnct(con, cur)
         else:
+            break
-           discnct(con, cur)
+    discnct(con, cur)
-           break
 def close():

修正

2020/10/08 05:37

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -300,7 +300,7 @@
         elif msg == "DB-DISCNCT":
             discnct(con, cur)
         else:
-            discnct(con, cur)
+           discnct(con, cur)
            break

修正

2020/10/08 05:34

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -223,7 +223,7 @@
     con = pymysql.connect(
         host = "localhost",
         user = "root",
-        password = "sh1n@n0pisql",
+        password = "root",
         db = "testdb",
         charset = "utf8"
     )

修正

2020/10/08 05:34

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -205,7 +205,7 @@
         con.commit()
 ```
-# 質問後追記 変更（2020/10/08 12:58）
+# 質問後追記 変更（2020/10/08 14:34）
 ```Python:
 from datetime import datetime
 import csv
@@ -223,7 +223,7 @@
     con = pymysql.connect(
         host = "localhost",
         user = "root",
-        password = "root",
+        password = "sh1n@n0pisql",
         db = "testdb",
         charset = "utf8"
     )
@@ -281,6 +281,7 @@
     while True:
         # キューにある先頭データを取り出す
         msg, args = data.get()
+        print(msg, args)
         if msg == "DB-CNCT":
             cnct()
         elif msg == "DB-INSERT":
@@ -299,8 +300,8 @@
         elif msg == "DB-DISCNCT":
             discnct(con, cur)
         else:
+            discnct(con, cur)
            break
-        time.sleep(0.1)
 def close():

修正

2020/10/08 05:33

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -205,20 +205,20 @@
         con.commit()
 ```
-# 質問後追記
+# 質問後追記 変更（2020/10/08 12:58）
 ```Python:
 from datetime import datetime
 import csv
 import pymysql
 import queue
 import threading
+import time
 import tkinter as tk
 tbl = "testtb"
 tmp = []
 def cnct():
-    global con, cur
     # データベース接続
     con = pymysql.connect(
         host = "localhost",
@@ -229,16 +229,17 @@
     )
     cur = con.cursor()
+    return con, cur
-def discnct():
+def discnct(con, cur):
-    global con, cur
     # データベース切断
     cur.close()
     con.close()
-def read_and_csvout():
+def read_and_csvout(cur):
-    global cur, tbl
+    global tbl
     cur.execute("SELECT * FROM " + tbl + ";")
     results = cur.fetchall()
     lst = []
@@ -251,8 +252,8 @@
             writer.writerow(lst[i])
-def clear():
+def clear(cur):
-    global cur, tbl
+    global tbl
     cur.execute("DELETE FROM " + tbl + ";")
@@ -275,34 +276,31 @@
 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)
 def close():
@@ -332,8 +330,6 @@
     thread = threading.Thread(target=loop, args=(data, ))
     thread.start()
-    data.put(("DB-CNCT", None))
     # ボタンバインド
     button1.bind("<ButtonRelease>", pushed1)
     button2.bind("<ButtonRelease>", pushed2)

追加

2020/10/08 03:59

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -203,4 +203,158 @@
                 データベースクリア()
         # コミット。データベースに変更を加えたらそれを反映させるために必要。
         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

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -30,7 +30,7 @@
     con = pymysql.connect(
         host = "localhost",
         user = "root",
-        password = "sh1n@n0pisql",
+        password = "root",
         db = "testdb",
         charset = "utf8"
     )

追加

2020/10/08 01:20

投稿

person

スコア224

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -177,6 +177,8 @@
 このときにButton2を押したときの処理が、メインスレッドだとバッファにキューに保存しているだけなのでMySQL操作しているスレッドの動作まで検知できません。
+（グローバル変数で適当なフラグを立てることを考えたのですが、Button1のデータ書き込みが終わったのか、Button2のデータ書き込みが終わったのか、そもそも書き込んでいないのかまではloop()内で区別できないような気がします。変数だけじゃなくコールバック関数などを駆使すればできる？）
 どのようにすれば 50,ButtonPushed2 をデータベースに保存した後でCSV出力をすることが可能でしょうか。
 （ただし、出力データ 50,ButtonPushed2 はあくまでサンプルデータにすぎないので、実際に保存するデータはどうなるか分かりません。そのためスレッドのループ内に下記のような指定をするのはなしでお願いします。）
@@ -194,7 +196,7 @@
             tmp = data.get()
             # tmpにあるデータをデータベースに保存
             cur.execute("INSERT INTO " + tbl + " VALUES(%s,%s,%s);", (tmp[0], tmp[1], tmp[2]))
-            # データの内容を指定して、CSV出力
+            # データの内容を指定して、CSV出力（これは解決策としては×）
             if tmp == ["50", "ButtonPushed2", ""]:
                 sqldata = データベース読み込み()
                 CSV出力(sqldata)