#coding=utf-8
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy import Column
from sqlalchemy.types import CHAR, Integer, String
from sqlalchemy.ext.declarative import declarative_base
Base=declarative_base()
class Product(Base):
    __tablename__=‘Product
 
‘
    id = Column(String(20), primary_key=True)  # 字段
    name = Column(String(20))  # 字段
    type= Column(String(20))  # 字段
    
engine = create_engine(‘mssql+pymssql://sa:root@localhost:1433/world‘)#初始化數據庫連接
DBSession=sessionmaker(bind=engine)#創建DBsesson類型
Base.metadata.create_all(engine)#創建表結構

#向數據庫寫入
session
 
=DBSession()#創建session對象
new_user=Product(id=‘1233445‘,name=‘寧夏一日遊‘,type=‘景+酒‘)#創建新Product對象
session.add(new_user)#添加到session
session.commit()#提交即保存到數據庫

#查詢
#創建Query查詢。filter是where條件，最後調用one()返回唯一行，如果調用all()則返回所有行
student=session.query(Product).filter(Product.id==‘1233445‘).one()
#打印對象的name,class_name屬性
print(
 
‘name:‘,student.name)
print(‘class_name：‘,student.type)

#查詢並更新數據
session.query(Product).filter(Product.id==‘1233445‘).update({Product.name:"寧夏中衛一日遊"})
session.commit()


#查詢並刪除數據
session.query(Product).filter(Product.id=‘1233445‘).delete()
session.commit()
session.close()

python數據庫的增刪改查