python mysqlでセレクトするときのエラー

Question

関数用のファイルと実行するファイル二つに分けてあります。
エラー内容は、

---

Traceback (most recent call last):
File "C:\Users\rice8_000\Desktop\fx\fxpro.py", line 8, in <module>
print(Soushisan_check())
File "C:\Users\rice8_000\Desktop\fx\app\app_mysql.py", line 16, in Soushisan_check
mycursor.execute(sql)
File "C:\Users\rice8_000\AppData\Local\Programs\Python\Python36-32\lib\site-packages\MySQLdb\cursors.py", line 216, in execute
while self.nextset():
File "C:\Users\rice8_000\AppData\Local\Programs\Python\Python36-32\lib\site-packages\MySQLdb\cursors.py", line 171, in nextset
db = self._get_db()
File "C:\Users\rice8_000\AppData\Local\Programs\Python\Python36-32\lib\site-packages\MySQLdb\cursors.py", line 201, in _get_db
raise ProgrammingError("cursor closed")
_mysql_exceptions.ProgrammingError: cursor closed

---

関数をまとめたファイルのコード

import MySQLdb


mydb = MySQLdb.connect(host="localhost",db="fxpro",user="staff",passwd="kqZwIGGqAo2oB6Gf",charset="utf8")
mycursor = mydb.cursor()


#*********************************************
#総資産をチェックします。
#総資産がマイナスまたは0以下の場合False
#総資産がプラスまたは1以上の場合True
#*********************************************
def Soushisan_check():
    sql = "Select 総資産 From 総資産 Where ID = 1"

    mycursor.execute(sql)

    result = mycursor.fetchall()

    for row in result:
        if (row[0] == 0):
            return False
        else:
            return True

    mycursor.close()
    mydb.close()

実行するファイル

from app.app_fxdata import *
from app.app_mysql import *


#総資産をチェックする
print(Soushisan_check())

今回使用するデータベースの仕様は、
データベース名が、fxpro
テーブル名が、総資産　です

結果としては、Trueが出る予定です。

Comments

[seastar3]

パスワードはさらすべきではありません。早く変えなければ。mysqlで日本語のテーブル名とフィールド名を使っているのでしょうか。テーブル名は"総資産"でいいのでしょうか。"fxpro"のデータベースの仕様が分かりません。

[World]

パスワードがすぐにかえさせていただきました。ありがとうございます。テーブルなども書かせていただきました。

Answer 1

総資産がマイナスまたは0以下の場合False

ならば、

        if (row[0] == 0):

は、

        if (row[0] <= 0):

です。

Answer 2

エラーの方ですが、Soushisan_check()が実行されるのは本当に一度だけなのでしょうか?

以下検証です。(都合上sqlite3を使っています。が多分大差ないと思います。)
foo.dbにはテーブルtable1、カラムpiyo、データbarが入っているとします。

# sqlFunc.py

import sqlite3 as sq

foo = sq.connect("./foo.db")
cur = foo.cursor()

def hoge():
    cur.execute("""SELECT piyo FROM table1;""")
    print(cur.fetchall()[0][0])

    cur.close()

if __name__=="__main__":
    hoge()

# sqlExc.py

from sqlFunc import hoge

hoge()
hoge()

以下実行結果です。

bar
Traceback (most recent call last):
  File "/Users/~/sqlExc.py", line 4, in <module>
    hoge()
  File "/Users/~/sqlFunc.py", line 7, in hoge
    cur.execute("""SELECT piyo FROM table1;""")
sqlite3.ProgrammingError: Cannot operate on a closed cursor.

1度目はうまくいきますが、
2度目のhoge()の呼び出しでエラーが発生していることがわかります。
(そのために実行は一度なのかどうかを聞きました。)

一言でいうと、カーソルの開閉が関数内で対になっていないのが原因です。

cur.close()は一度目の実行でなされてしまっているので、実行するにはもう一度接続する必要があります。

ですから、以下のように直してみます。

import sqlite3 as sq

foo = sq.connect("./foo.db")
#cur = foo.cursor() <- 消す

def hoge():
    cur = foo.cursor() # <- こっちに移動
    
    cur.execute("""SELECT piyo FROM table1;""")
    print(cur.fetchall()[0][0])

    cur.close()

if __name__=="__main__":
    hoge()

こうするとちゃんと2度barが表示されます。

質問者様のコードの場合はこう直すといいと思います。

(9/27 14:30頃更新)

import MySQLdb


mydb = MySQLdb.connect(host="localhost",db="fxpro",user="staff",passwd="****************",charset="utf8")

#*********************************************
#総資産をチェックします。
#総資産がマイナスまたは0以下の場合False
#総資産がプラスまたは1以上の場合True
#*********************************************
def Soushisan_check():

    mycursor = mydb.cursor()
    sql = "Select 総資産 From 総資産 Where ID = 1"

    mycursor.execute(sql)

    result = mycursor.fetchall()

    for row in result:
        if (row[0] == 0):
            return False
        else:
            return True

    mycursor.close()
    # mydb.close() <- 消す

MySQLdbの方で試していないので、これで直るかはちょっと自信が無いですが、試してみてください。

長文失礼しました。m(_ _)m

##追記

関数が一つだったので移動する解決方法をのせましたが、
コメントでも書いた通り閉じる関数を別に用意する方が早かったかもしれません。

import MySQLdb


mydb = MySQLdb.connect(host="localhost",db="fxpro",user="staff",passwd="****************",charset="utf8")
mycursor = mydb.cursor()


#*********************************************
#総資産をチェックします。
#総資産がマイナスまたは0以下の場合False
#総資産がプラスまたは1以上の場合True
#*********************************************
def Soushisan_check():
    sql = "Select 総資産 From 総資産 Where ID = 1"

    mycursor.execute(sql)

    result = mycursor.fetchall()

    for row in result:
        if (row[0] == 0):
            return False
        else:
            return True

def closeDb(): # <- 追加
    mycursor.close()
    mydb.close()

from app.app_fxdata import *
from app.app_mysql import *


#総資産をチェックする
print(Soushisan_check())

# 全部の処理が終わったら閉じる
closeDb()

Comments

[World]

丁寧な説明ありがとうございます。
結果としては、エラーがでてしましました。
Soushisan_check()をする前に、Insert処理をしています。それがまずいということでしょうか？
一応gituhbにのせましたので、時間がありましたら見てほしいです。
https://github.com/zerone08/fxpro.git

[namnium1125]

あぁ、忘れていたことがありました。すみません。。mydb.close()が原因だと考えられます。これを消すか、mydb = MySQLdb.connect(...)をすべての関数内に書くか、どちらかをしてください。

私は前者の方で回答を編集しました。以前の回答は履歴からみてください。m(_ _)m

[namnium1125]

もしかしたらmydb.close()が呼ばれないのは危ないかもしれないので、私の方法で行う場合はclose()する関数をapp_mysql.pyの中で別に用意して、fxpro.pyの方から最後に呼ぶようにするといいかもしれません。

[namnium1125]

追記しました。よろしくお願いします。m(_ _)m

[World]

ありがとうございます！！できました！！