SQLAlchemy既存データベースへの接続

1データベースとアカウントの作成

テスト用のデータベースalchemyとアカウントalc、パスワードalcを作成します.

CREATE DATABASE alchemy;
CREATE USER 'alc'@'localhost' IDENTIFIED BY 'alc';
USE alchemy;
GRANT ALL ON alchemy.* TO 'alc'@'localhost';
FLUSH PRIVILEGES ;

2構成パラメータの作成

ファイルに置くpyで、

HOSTNAME = 'localhost'
DATABASE = 'alchemy'
USERNAME = 'alc'
PASSWORD = 'alc'
DB_URI = 'mysql://{}:{}@{}/{}'.format(
    USERNAME, PASSWORD, HOSTNAME, DATABASE
)

3 SQLAlchemyによるデータベースの作成

createというPythonファイルを新規作成table.py、論理を記述します.SQLAlchemyのORMでデータベースを作成し、データを挿入してクエリーします.

# -*- coding:utf-8 -*-
from sqlalchemy import create_engine, Column, Integer, String, Sequence
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

from configs import DB_URI

eng = create_engine(DB_URI)     #   MySQLdb   connection，  API
Base = declarative_base()       # sqlalchemy  

class School(Base):
    __tablename__ = 'school'
    id = Column(Integer, Sequence('school_id_seq'), primary_key=True, autoincrement=True)
    name = Column(String(30))

#   Base  ，  Base   school  
Base.metadata.drop_all(bind=eng)
Base.metadata.create_all(bind=eng)

#   session  
Session = sessionmaker(bind=eng)
session = Session()

#  ，  commit
session.add(School(name='Adam'))
session.add_all([School(name=student_name) for student_name in ('James', 'Marrie', 'Charlie', 'David')])
session.commit()

#  
def show_query_result(rest):
    for student in rest:
        print student.name

#  
rest = session.query(School).all()
show_query_result(rest)

結果:

Adam
James
Marrie
Charlie
David

MySQLで確認:

mysql> USE alchemy; SELECT * FROM school LIMIT 10;
Database changed
+----+---------+
| id | name    |
+----+---------+
|  1 | Adam    |
|  2 | James   |
|  3 | Marrie  |
|  4 | Charlie |
|  5 | David   |
+----+---------+
5 rows in set (0.00 sec)

mysql> DESC school;
+-------+-------------+------+-----+---------+----------------+
| Field | Type        | Null | Key | Default | Extra          |
+-------+-------------+------+-----+---------+----------------+
| id    | int(11)     | NO   | PRI | NULL    | auto_increment |
| name  | varchar(30) | YES  |     | NULL    |                |
+-------+-------------+------+-----+---------+----------------+
2 rows in set (0.00 sec)

4 SQLAlchemy既存のデータベースへの接続

新規ファイルreflect_table.py SQLAlchemy接続後のデータをテストする機能です.

# -*- coding:utf-8 -*-
from sqlalchemy import *
from sqlalchemy.orm import create_session
from sqlalchemy.ext.declarative import declarative_base

from configs import DB_URI

Base = declarative_base()
engine = create_engine(DB_URI)
metadata = MetaData(bind=engine)

class School(Base):
    ''' ， ： 、metadata（ ）、autoload=True'''
    __table__ = Table('school', metadata, autoload=True)

def show_query_result(rest):
    for student in rest:
        print student.name

#  
session = create_session(bind=engine)

#  
rest = session.query(School).all()
show_query_result(rest)

print '-' * 15

#  
session.begin()
session.add(School(name='Derek'))
session.commit()

#  
rest = session.query(School).all()
show_query_result(rest)

結果は成功しました.クエリーしたり、データを追加したりできます.

Adam
James
Marrie
Charlie
David
---------------
Adam
James
Marrie
Charlie
David
Derek

5リファレンス

公式ドキュメントは主にSQLAlchemyのreflect部分です.
Python Web開発実戦
How to automatically reflect database to sqlalchemy declarative?