首先安裝sqlalchemy，安裝方法有兩種：通過官網下載原始碼進行安裝；使用pip install sqlachemly

1.建立操作資料庫介面模組api.py，

描述:

在介面模組中首先建立一個engine，這裡關聯的是mysql資料庫，也可以是其他型別的資料庫

然後定義了幾個訪問資料庫的介面函式，提供對資料庫的新增、刪除、查詢操作

from sqlalchemy import create_engine
from sqlalchemy import func
from sqlalchemy.pool import NullPool
from sqlalchemy.orm import sessionmaker

class API(object):
        def __init__(self):
	    args = 'mysql://root:
 
[email protected]/myDB?charset=utf8'
	    kwds = NullPool
	    engine = create_engine(args,poolclass=kwds)
	    Session = sessionmaker(bind=engine)
	    self.session = Session()
	def create(self, db, **body):
	    self.session.add(db(**body))
	    return 'CREATED'
	def get_all_content(self, db):
	    result = list(t.__dict__ for t in self.session.query(db).all())
	    for i in xrange(0, len(result)
	        result.pop('_sa_instance_state', None)
	    return 'OK', result
	def delete_context(self, db, db_attr, value):
	    res = self.session.query(db).filter(db_attr == value).delete()
	    if res:
	        self.session.commit()
	        return 'OK'
	    else:
	        return False
	def delete_all(self, db):
	    self.session.query(db).delete()
	    self.session.commit()
	    return 'OK'
 

2.建立資料庫訪問儲存、模型模組model.py，這裡定義了一個名字叫test的表，其中包含三個欄位id（自動增長），name，sex

from sqlalchemy import Column, Integer, String,schema
from sqlalchemy.ext.declarative import declarative_base
def table_args():
        return {
            'mysql_engine': 'InnoDB',
            'mysql_charset': 'utf8'
        }

Base = declarative_base()

class Test(Base):
        """defined a Test"""
	__tablename__ = 'test'
	__table_args__ = (
	    schema.UniqueConstraint('id', name = 'uniq_test_id'),
		table_args()
	)
	id = Column(Integer, primary_key=True,autoincrement='auto',nullable=False)
	name = Column(String(255), nullable=False)
	sex = Column(String(40), nullable=False)
 

from model import Test
import api
def query_all_in_test_table():
    db_api = api.API()
    rv, date = db_api.get_all_content(Test)
    print date