python sqlalchemyモジュール使用

3520 ワード

sqlalchemyは、複数のデータベースsqlite、oracle、mysqlなどに接続できます.以下はsqliteの例です.
import sqlite3
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,Integer,String,DATE,ForeignKey
from sqlalchemy.orm import sessionmaker,relationship
from sqlalchemy import func
from datetime import datetime

#  sudentsInfo.db3     ,     
conn = sqlite3.connect('F:\    \       \pycharmProfessional\workspace\c14\sudentsInfo.db3')

#echo=True      
engine = create_engine('sqlite:///F:\    \       \pycharmProfessional\workspace\c14\sudentsInfo.db3')
Base = declarative_base()

class User(Base):
    __tablename__ = 'user' #  
    id = Column(Integer,primary_key=True)
    name = Column(String(32))
    password = Column(String(64))

    def __repr__(self):
        return '%s name:%s'%(self.id,self.name)

class Student(Base):
    __tablename__ = 'student'
    id = Column(Integer,primary_key=True)
    name = Column(String(32),nullable=False)
    register_date = Column(DATE,nullable=False)
    def __repr__(self):
        return '%s name:%s'%(self.id,self.name)

class StudyRecord(Base):
    __tablename__ = 'study_record'
    id = Column(Integer,primary_key=True)
    day = Column(Integer)
    status = Column(String(32),nullable=False)
    stu_id = Column(Integer,ForeignKey('student.id')) #  ,   student 
    student = relationship('Student',backref = 'my_study_record') #student study_record        
    # student = Student()
    def __repr__(self):
        return '%s day:%s Student:%s'%(self.student.name,self.day,self.student)


Base.metadata.create_all(engine) #     

#         session class,         ,    
Session_class = sessionmaker(bind=engine)
session = Session_class() #  session  
# s1 = Student(name='Alex',register_date=datetime(2016,6,5))
# s2 = Student(name='Tim',register_date=datetime(2016,4,5))
# s3 = Student(name='Max',register_date=datetime(2016,3,5))
# s4 = Student(name='Eric',register_date=datetime(2016,2,5))
#
# study_obj1 = StudyRecord(day=1,status='Yes',stu_id=1)
# study_obj2 = StudyRecord(day=2,status='No',stu_id=1)
# study_obj3 = StudyRecord(day=3,status='Yes',stu_id=1)
# study_obj4 = StudyRecord(day=1,status='Yes',stu_id=2)
#
# session.add_all([s1,s2,s3,s4,study_obj1,study_obj2,study_obj3,study_obj4])

stu_obj = session.query(Student).filter(Student.name == 'Alex').first()
print(stu_obj.my_study_record)
session.commit()

# User_obj = User(name='Tim',password='123456') #          
# User_obj = User(name='Kite',password='123456')
# session.add(User_obj) #            session 
# session.commit() #      User_obj  

#  
# data= session.query(User).filter_by().all()
# data= session.query(User).filter(User.id>2).filter(User.id<4).first() #     
# print(data)

#  
# data.name = 'Bob'
# session.commit()
# print(data)

#  
# fake_user = User(name = 'Rain',password='123456')
# session.add(fake_user)
# fake_data = Session.query(User).filter(User.name.in_(['Tim','Rain'])).all()
# print(fake_data)
# session.rollback()
# print(fake_data)
# session.commit()

#  
# fake_data = session.query(User).filter(User.name.in_(['Tim','Rain'])).count()
# print(fake_data)

#f  
# data = session.query(func.count(User.name),User.name).group_by(User.name).all()
# print(data)