[Flask] MySQL과 연동하여 데이터 Select

설치 파일들

!pip install flask
!pip install flask-restful
!pip install flask-mysql
!pip install sqlalchemy
!pip install mysql-connector-python

import 

from flask      import Flask, request, jsonify, current_app
from flask.json import JSONEncoder
from sqlalchemy import create_engine, text
from flaskext.mysql import MySQL
import json
import pymysql
import pandas as pd

---

작동방법 확인

def getList(u_id):    
    gil_db = pymysql.connect(
        host='urlhost', 
        port=포트번호, 
        user='계정', 
        passwd='계정 비밀번호', 
        db='DB 이름', 
        charset='utf8'
    )
    cursor = gil_db.cursor()
    
    #* 쓰는걸 지양하자. 파이썬 ;이 있거나 없거나 상관이 없다.
    sql = f"""
            SELECT cctv_id, car_num, car_inout_at, sac_content, sac_at, car_img_link
            FROM tb_security_alarm_car
            WHERE u_id = '{u_id}'
            """
    cursor.execute(sql)
    rows = cursor.fetchall()
#     print(rows[2][2])
    
    # price = []
    list = []
    for row in rows:
        # price.append(row[2])
        list.append(row)
    
    gil_db.close()
    return list

if __name__ == '__main__':
    arr = getList("test1")
    arr = np.array(arr)
    print(arr)

---

DB 연결 및 쿼리 작성 함수

# DB 연결 및 쿼리 작성
def db_connector(u_id):
    db = pymysql.connect(host='urlhost', port=포트번호, user='계정', passwd='계정 비밀번호', db='DB이름', charset='utf8')
    cursor = db.cursor()
#     sql = cctv_select
    sql = "SELECT * FROM tb_security_alarm_human WHERE U_ID=%s;"
#     param = u_id
    cursor.execute(sql, [u_id])
    result = cursor.fetchall()
    db.close()
    return str(result)