PythonでSSH接続のコードをクラス化したら接続ができなくなった

PythonのSQL操作をクラス化しようとしていますが、うまくいきません。
クラス化する前は接続できていたので、接続情報などは間違っていないのですが、クラス化で問題があるようで手詰まりとなってしまいました。

言語：Python　3.7
SQL：MySQL　5.7
開発環境：Visual Studio Code
XServerにあるMySQLに接続するためにSSH接続をしています。

def init　の中ではDatabaseに接続できていますが、
def create_table　の中では接続が切れてしまっているようです。

どのように修正したらよろしいでしょうか？
ご教授いただけますと幸いです。
よろしくお願いいたします。

Python
1class access_MySQL():
2    def __init__(self):
3        try:
4            port_num = 10022
5            with SSHTunnelForwarder(
6            ('XXXXX.xserver.jp',port_num),
7            ssh_username = 'XXXXX',
8            ssh_password = 'XXXXX',
9            ssh_pkey = 'XXXXX',
10            remote_bind_address=('XXXXX.xserver.jp',3306)
11            )as server:
12                # 接続する
13                self.conn = mydb.connect(
14                    host='localhost',
15                    port=server.local_bind_port,
16                    user='XXXXX',
17                    password='XXXXX',
18                    database='XXXXX'
19                ) 
20
21                # コネクションの設定
22                self.cur = self.conn.cursor()
23                print(self.conn.is_connected()) # Trueが返される
24
25        except:
26            print("データベースに接続できませんでした")
27
28    def create_table(self):
29        try:
30            print(self.conn.is_connected())  # Falseが返される
31
32            sql = "CREATE TABLE `TEST2` ("
33            sql = sql + "`URL` varchar(100) DEFAULT NULL,"
34            sql = sql + "`TITLE` varchar(100) DEFAULT NULL)"
35
36            self.cur.execute(sql)　　　　# 実行されずエラーになりexceptに飛ぶ
37            return True, 'Success to create table'
38        except mydb.connection.errors as err:
39             return False, str(err.errno) + " : " + query
40
41
42access_db = access_MySQL()
43access_db.create_table()
44

8524ba23

2021/09/26 04:25

クラス化前のコードも提示したほうがよいかと思います。パッとみて、提示コードではserver変数の寿命がinit内で終わっているのが問題の気がしますが。

syoco0330

2021/09/26 12:19

コメントありがとうございます。 with文を無くすことで解消することができました。

行動規範の内容に同意します

回答2件

ベストアンサー

クラス化の問題ではなく、withの使いかたの問題です。

with文は、with文を抜け出すときにcloseします。

公式ドキュメント 8.5. with 文に、

7.コンテキストマネージャの exit() メソッドが呼ばれます。

と書かれている処理です。

後で使いたいのであれば、with文を使うべきではありません。

投稿2021/09/26 04:28

ppaul

総合スコア24670

syoco0330

2021/09/26 12:22

コメントありがとうございます。教えていただいた通り、with文を無くすことで解消することができました。大変助かりました、ありがとうございました。

行動規範の内容に同意します

With文を無くすことで解消。
下記がエラーにならないコードサンプルです。

Python
1class access_MySQL():
2    def __init__(self):
3        try:
4            port_num = 10022
5            server = SSHTunnelForwarder(
6            ('XXXXX.xserver.jp',port_num),
7            ssh_username = 'XXXXX',
8            ssh_password = 'XXXXX',
9            ssh_pkey = 'XXXXX',
10            remote_bind_address=('XXXXX.xserver.jp',3306)
11            )
12
13            server.start()
14
15            self.conn = mydb.connect(
16                host='localhost',
17                port=server.local_bind_port,
18                user='XXXXX',
19                password='XXXXX',
20                database='XXXXX'
21            )
22
23            self.cur = self.conn.cursor()
24            print(self.conn.is_connected())
25
26        except:
27            print("データベースに接続できませんでした")
28
29    def create_table(self):
30        try:
31            print(self.conn.is_connected())  
32
33            sql = "CREATE TABLE `TEST2` ("
34            sql = sql + "`URL` varchar(100) DEFAULT NULL,"
35            sql = sql + "`TITLE` varchar(100) DEFAULT NULL)"
36
37            self.cur.execute(sql)　　　　
38            return True, 'Success to create table'
39        except mydb.connection.errors as err:
40             return False, str(err.errno) + " : " + query
41
42
43access_db = access_MySQL()
44access_db.create_table()