sqlalchemy_mysql

sqlalchemy-mysql

參考：

• Python之使用Pandas庫實現MySQL數據庫的讀寫
• SQLAlchemy的簡單使用
• sqlalchemy學習筆記
• python使用sqlalchemy鏈接mysql數據庫
• doc: pandas.read_sql
• doc: pandas.read_sql_query
• doc: pandas.DataFrame.to_sql

第三方庫安裝與簡單使用

• PyMySQL

  • PEP 249 -- Python Database API Specification v2.0

  pip install PyMySQL

  import pymysql
  
  # pymysql.connect('<主機HOST>', '<用戶名>', '<密碼>', '<數據庫名>'[[, charset='<編碼>'][, port=<端口(默認3306)>]])
  # 建立-數據庫鏈接對象
  conn = pymysql.connect('localhost:3306', 'root', 'root', 'mysql', charset='utf8')
  # 建立-遊標對象
  cursor = conn.cursor()
  # 執行SQL語句(查詢MySQL版本)
  cursor.execute('select version()')
  # 獲取一條SQL語句（查詢類型）執行結果
  cursor.fetchone()
  # 關閉遊標
  cursor.close()
  # 關閉數據庫鏈接（釋放資源）
  conn.close()

• SQLAlchemy

  • Working with Engines and Connections

  pip install SQLAlchemy

  # 導入建立引擎的方法
  from sqlalchemy import create_engine
  
  # 數據庫配置
  db_config = {
      'username': 'root',
      'password': 'root',
      'host': '127.0.0.1',
      'port': 3306,
      'database': 'mysql',
      'charset': 'utf8'
  }
  # SQLAlchemy鏈接URI
  uri = 'mysql+pymysql://{username}:{password}@{host}:{port}/{database}?charset={charset}'.format(**db_config)
  # 建立數據庫引擎
  engine = create_engine(uri)
  # 發動引擎，獲得一個SQLAlchemy中的數據庫鏈接
  conn = engine.connect()
  # 執行sql語句（查詢當前時間）（返回一代理對象）
  rp = conn.execute('select now()')
  # 獲取結果
  rp.fetchone()
  # 關閉結果代理對象
  rp.close()
  # 關閉鏈接
  conn.close()
  # 查看鏈接是否已經關閉
  print(conn.closed)

• SQLAlchemy-Utils

  • sqlalchemy_utils.functions.database_exists(url)
  • sqlalchemy_utils.functions.create_database(url, encoding='utf8', template=None)
  • sqlalchemy_utils.functions.drop_database(url)

  pip install SQLAlchemy-Utils

  from sqlalchemy import create_engine
  import sqlalchemy_utils
  
  # 數據庫配置
  db_config = {
      'username': 'root',
      'password': 'root',
      'host': '127.0.0.1',
      'port': 3306,
      'database': 'hello',
      'charset': 'utf8'
  }
  # SQLAlchemy鏈接URI
  uri = 'mysql+pymysql://{username}:{password}@{host}:{port}/{database}?charset={charset}'.format(**db_config)
  # 判斷數據是否存在
  if not sqlalchemy_utils.database_exists(uri):
      print('不存在')
      sqlalchemy_utils.create_database(uri)
  else:
      print('存在')
      sqlalchemy_utils.drop_database(uri)

SQLAlchemy-操做數據庫

SQLAlchemy鏈接關係型數據庫URI(字符串)格式:
數據庫類型+數據庫驅動名稱://用戶名:口令@機器地址:端口號/數據庫名