Python+flaskを使用してMySQLデータベースのCRUD操作を行う

Python+Flask による MySQL データベースの CRUD 操作とデータの表示#

一、Python で MySQL データベースに接続する#

1. PyMySQL ドライバのインストール#

PyMySQL は Python3.x バージョンで MySQL サーバーに接続するためのライブラリであり、Python2 では mysqldb を使用します。

pip3 install pymysql

2. データベーステーブルのテストデータ#

Navicat を使用することも、コマンドラインを使用することもできます。テーブルを作成します。
ここに画像の説明を挿入

3. データベースに接続する#

import pymysql
# データベース接続を開く
db = pymysql.connect(host="localhost", user="root", password="123456", database="test")
# cursor()メソッドを使用して操作カーソルを取得
cursor = db.cursor()
# SQL文
sql = "select * from info"
try:
    # SQL文を実行
    cursor.execute(sql)
    # クエリの操作の一つ、すべてのレコードを取得
    result = cursor.fetchall()
    # テーブルデータを印刷
    for row in result:
        id = row[0]
        name = row[1]
        age = row[2]
        print(id, name, age)
except:
    print("エラー！")
# データベースを閉じる
db.close()

ここに画像の説明を挿入

二、Flask+Python によるデータベースデータの操作#

Flask に関する知識：Flask フレームワーク学習ノート

1. データをクエリする#

この部分の操作は、データベース操作専用の py ファイルと Flask 操作専用の py ファイルに分かれています。

sql_lianjie.py データベース操作のためのクラスを定義します。

import pymysql
class Mysql(object):
    def __init__(self):
        try:
            self.db = pymysql.connect(host="localhost", user="root", password="123456", database="test")
            # カーソルオブジェクト
            self.cursor = self.db.cursor()
            print("接続成功！")
        except:
            print("接続失敗！")
    # データをクエリする関数
    def getdata(self):
        sql = "select * from info"
        # SQL文を実行
        self.cursor.execute(sql)
        # すべてのレコードを取得
        results = self.cursor.fetchall()
        return results
    # 閉じる
    def __del__(self):
        self.db.close()

sql_flask.py は Flask ルーティングを使用してデータを表示します。
データベース操作のクラスをインポートすることを忘れないでください。

from flask import Flask, render_template, request
import pymysql
# データベース操作クラスをインポート
from sql_lianjie import Mysql
app = Flask(__name__)

@app.route("/info", methods=['GET', 'POST'])
def info():
    # 呼び出し
    db = Mysql()
    results = db.getdata()
    return render_template("sql_select.html", results=results)
    
if __name__ == "__main__":
    app.run(app.run(debug=True, port=5000, host='127.0.0.1'))

sql_select.html このページはデータをウェブページに表示します（部分的なコードのみ表示）。

<body>
<div>
    <h4>データをクエリする</h4>
    <table border="1" width="30%" weight="30%">
        <thead>
        <tr>
            <th>id</th>
            <th>name</th>
            <th>age</th>
        </tr>
        </thead>
        <tbody>
            {% for result in results %}
                <tr>
                    <td>{{ result[0]}}</td>
                    <td>{{ result[1]}}</td>
                    <td>{{ result[2]}}</td>
                    <td><a href="/delete?id={{ result[0] }}"><button>削除</button></a></td>
                    <td><a href="/submit_insert"><button>挿入</button></a></td>
                    <td><a href="/submit_update"><button>更新</button></a></td>
                </tr>
            {% endfor %}
        </tbody>
    </table>
</div>

結果：ウェブページを開く：http://localhost:5000/info

2. データを挿入する#

sql_lianjie.py

def insertdata(self, results):
        sql = "insert into info(name, age) values('%s', '%s')" % (results['name'], results['age'])
        sql1 = "ALTER TABLE info DROP id"
        sql2 = "ALTER TABLE info ADD id int NOT NULL FIRST"
        sql3 = "ALTER TABLE info MODIFY COLUMN id int NOT NULL AUTO_INCREMENT, ADD PRIMARY KEY(id)"
        try:
            self.cursor.execute(sql)
            self.cursor.execute(sql1)
            self.cursor.execute(sql2)
            self.cursor.execute(sql3)
            self.db.commit()
        except:
            # エラーが発生した場合はロールバックします。これにより、エラーが発生してもテーブルデータに影響を与えません。
            self.db.rollback()
        return

sql_flask.py

@app.route("/submit_insert")
def submit_insert():
    return render_template("sql_insert.html")
    
@app.route("/insert", methods=['GET', 'POST'])
def insert():
    if request.method == "POST":
        results = request.form
        db = Mysql()
        db.insertdata(results)
        return render_template("result_insert.html", results=results)

sql_insert.html

<div>
    <h4>このページでデータを挿入できます</h4>
    <!-- formタグのmethod属性を変更してデータリクエストの方法を変更します -->
    <form action="http://localhost:5000/insert" method="POST">
        name:<input type="text" name="name" autocomplete="off"><br/><br/>
        age:<input type="text" name="age" autocomplete="off"><br/><br/>
        <button onclick="myFunction()">送信</button>       <a href="/info"><button>データを表示</button></a>
        <p id="demo"></p>
    </form> 
    <script>
        function myFunction(){
            var txt;
            confirm("データが正常に挿入されました！");
            txt = "あなたはデータを正常に挿入しました！データを表示をクリックすると更新されたデータを見ることができます";
            document.getElementById("demo").innerHTML = txt;
        }
    </script>
</div>

result_insert.html

<body>
   あなたはデータを正常に挿入しました！データを表示をクリックすると更新されたデータを見ることができます！
   <br>
   挿入されたnameは：{{results['name']}}<br>
   挿入されたageは：{{results['age']}}<br>
   <br>
   <a href="/info"><button>データを表示</button></a>
</body>

結果：infoこのページで挿入ボタンをクリックすると、データ挿入ページに移動します。このページで挿入するデータを入力します（id は自動増分のため入力する必要はありません）。

送信ボタンをクリックすると、データが正常に挿入されたことが確認できます。

データを表示ボタンをクリックすると、挿入されたデータを見ることができます。

3. データを更新する#

sql_lianjie.py

def updatedata(self, results):
        sql = "update info set name='%s', age='%s' where id='%s'" % (results['name'], results['age'], results['id'])
        sql1 = "ALTER TABLE info DROP id"
        sql2 = "ALTER TABLE info ADD id int NOT NULL FIRST"
        sql3 = "ALTER TABLE info MODIFY COLUMN id int NOT NULL AUTO_INCREMENT, ADD PRIMARY KEY(id)"
        try:
            self.cursor.execute(sql)
            self.cursor.execute(sql1)
            self.cursor.execute(sql2)
            self.cursor.execute(sql3)
            self.db.commit()
        except:
            # エラーが発生した場合はロールバックします。これにより、エラーが発生してもテーブルデータに影響を与えません。
            self.db.rollback()
        return

sql_flask.py

@app.route("/submit_update")
def submit_update():
    return render_template("sql_update.html")
    
@app.route("/update", methods=['GET', 'POST'])
def update():
    if request.method == "POST":
        results = request.form
        db = Mysql()
        db.updatedata(results)
        return render_template("result_update.html", results=results)

sql_update.html

<div>
    <h4>このページでデータを更新します</h4>
    <!-- formタグのmethod属性を変更してデータリクエストの方法を変更します -->
    <form action="http://localhost:5000/update" method="POST">
        更新する必要のあるidを入力してください:<input type="text" name="id" autocomplete="off"><br/>
        更新するnameを入力してください:<input type="text" name="name" autocomplete="off"><br/>
        更新するageを入力してください:<input type="text" name="age" autocomplete="off"><br/>
        <input type="submit" value="送信">
    </form> 
    <a href="/info"><button>データを表示</button></a>
</div>

result_update.html

<body>
   あなたはデータを正常に更新しました！
   <br>
   データを表示をクリックすると更新されたデータを見ることができます！
   <br>
   更新されたidは：{{results['id']}}<br>
   更新されたnameは：{{results['name']}}<br>
   更新されたageは：{{results['age']}}<br>
   <br>
   <a href="/info"><button>データを表示</button></a>
</body>

結果は挿入データの効果を参考にしてください。

4. データを削除する#

sql_lianjie.py

def deletedata(self, id):
        sql = "delete from info where id=" + str(id)
        sql1 = "ALTER TABLE info DROP id"
        sql2 = "ALTER TABLE info ADD id int NOT NULL FIRST"
        sql3 = "ALTER TABLE info MODIFY COLUMN id int NOT NULL AUTO_INCREMENT, ADD PRIMARY KEY(id)"
        try:
            # SQL文を実行
            self.cursor.execute(sql)
            self.cursor.execute(sql1)
            self.cursor.execute(sql2)
            self.cursor.execute(sql3)
            # データをコミット
            self.db.commit()
        except:
            # エラーが発生した場合はロールバックします。これにより、エラーが発生してもテーブルデータに影響を与えません。
            self.db.rollback()
        return

sql_flask.py

@app.route("/delete")
def delete():
    id = request.args.get("id")
    db = Mysql()
    db.deletedata(id)
    return render_template("result_delete.html", id=id)

result_delete.html

<body>
   あなたはidが:{{id}}のデータを正常に削除しました！
   <br>
   データを表示をクリックすると更新されたデータを見ることができます！
   <br>
   <br>
   <a href="/info"><button>データを表示</button></a>
</body>

更新、変更、削除操作の中での sql1-3 の役割は、テーブル内のデータが変更されたときに id が自動的に更新されることです。つまり、これらの 3 行を加えないと、中間のデータを削除した場合、中間のデータの id が自動的に再順序付けされません。
コード：
既存の主キーを削除：ALTER TABLE news DROP NewsID;
新しい主キーを追加：ALTER TABLE news ADD NewsID int NOT NULL FIRST;
新しい主キーを設定：ALTER TABLE news MODIFY COLUMN NewsID int NOT NULL AUTO_INCREMENT, ADD PRIMARY KEY(NewsID);