SQLAlchemy MySQL 基础
标签：
查看更多关于SQLAlchemy MySQL 基础的详细内容...
声明：本文来自网络，不代表【好得很程序员自学网】立场，转载请注明出处：http://www.haodehen.cn/did160509
SQLAlchemy MySQL 基础
= ‘ Steve ‘
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
Base = declarative_base()
# define the schema of table
class Users2(Base):
__tablename__ = ‘ users2 ‘
name = Column(String(45), nullable= True)
id = Column(Integer, primary_key= True)
# you can direct query database, but it is not recommended
def test_conn():
username = ‘ root ‘
passwd = ‘ 123 ‘
schema = ‘ test ‘
engine = create_engine(
" mysql://{0}:{1}@127.0.0.1/{2}?charset=utf8&use_unicode=0 " .format(username, passwd, schema))
result = engine.execute( " select name from users2 " )
for row in result:
print " name: " , row[ ‘ name ‘ ]
result.close()
def conn():
username = ‘ root ‘
passwd = ‘ 123 ‘
schema = ‘ test ‘
engine = create_engine(
" mysql+mysqldb://{0}:{1}@127.0.0.1/{2}?charset=utf8&use_unicode=0 " .format(username, passwd, schema))
Base.metadata.bind = engine
DBSession = sessionmaker(bind= engine)
session = DBSession()
return session
def query():
session = conn()
rows = session.query(Users2).all()
for row in rows:
print row.id, row.name
def insert():
user = Users2(name= " steve " , id=3 )
session = conn()
session.add(user)
session.commit()
def delete():
session = conn()
user = session.query(Users2).filter_by(name= ‘ steve2 ‘ ).one()
print " delete user: " , user.name
session.delete(user)
session.commit()
def update():
session = conn()
user = session.query(Users2).filter_by(name= ‘ steve ‘ ).one()
user.name = ‘ steve2 ‘
session.commit()
if __name__ == " __main__ " :
query()
print
# insert()
# delete()
# update()
query()
阅读：22次