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

참고 블로그)

https://homzzang.com/b/py-42

홈짱닷컴

---

설치 파일들

!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

 

테이블에 행 1개 삽입

# 테이블에 행 1개 삽입
import mysql.connector



mydb = mysql.connector.connect(

  host="host url",
    
  port = 포트번호,

  user="user 계정",

  password="계정 비밀번호",

  database="DB 이름"

)



mycursor = mydb.cursor()

sql = "INSERT INTO tb_cctv1(u_id, rtsp_address, rtsp_address2, cctv_loc) VALUES(%s, %s, %s, %s)"
val = ("test3", "rtsp://210.99.70.120:1935/live/cctv009.stream", "rtsp://210.99.70.120:1935/live/cctv015.stream", "이건 몰라유")

mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, "record inserted.")

 

테이블에 행 여러 개 삽입

# 테이블에 행 여러 개 삽입
import mysql.connector


mydb = mysql.connector.connect(

  host="host url",
    
  port = 포트번호,

  user="user 계정",

  password="계정 비밀번호",

  database="DB 이름"

)



mycursor = mydb.cursor()

sql = "INSERT INTO tb_cctv1(u_id, rtsp_address, rtsp_address2, cctv_loc) VALUES(%s, %s, %s, %s)"
# 하나하나 넣을 거 아니면 for문 추천드림★
val = [
        ("test3", "rtsp://210.99.70.120:1935/live/cctv009.stream", "rtsp://210.99.70.120:1935/live/cctv015.stream", "이건 몰라유"),
        ("test4", "rtsp://210.99.70.120:1935/live/cctv018.stream", "rtsp://210.99.70.120:1935/live/cctv020.stream", "이건 몰라유")
        ]

mycursor.executemany(sql, val)

mydb.commit()

print(mycursor.rowcount, "record inserted.")

# 삽입된 마지막 레코드의 ID 가져오기
# mycursor.lastrowid)
# print("1 record inserted, ID:", mycursor.lastrowid)