Python數據庫(三)-使用sqlalchemy建立表

首先須要安裝sqlalchemy
根據所需狀況調用數據庫接口，對數據庫進行操做
pymysql：
mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
MySQL-Python：
mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
官方文檔：http://docs.sqlalchemy.org/en/latest/dialects/index.html

# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR"

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,String,Integer

engine = create_engine("mysql+pymysql://root:root@127.0.0.1/test",encoding="utf-8",echo=True,max_overflow=5)
#鏈接mysql數據庫，echo爲是否打印結果

Base = declarative_base() #生成orm基類

class User(Base): #繼承生成的orm基類
    __tablename__ = "sql_test" #表名
    id = Column(Integer,primary_key=True) #設置主鍵
    user_name = Column(String(32))
    user_password = Column(String(64))

class Admin(Base):
    __tablename__ = "admin"
    id = Column(Integer, primary_key=True)
    username = Column(String(32))
    password = Column(String(64))

Base.metadata.create_all(engine) #建立表結構
#父類Base調用全部繼承他的子類來建立表結構

運行

echo設置爲True打印了返回的結果

在mysql中查看結果

表也建立成功

若是已經有了同名的表，將不會覆蓋建立該表

給表插入數據

# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR"

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,String,Integer
from sqlalchemy.orm import sessionmaker

engine = create_engine("mysql+pymysql://root:root@127.0.0.1/test",encoding="utf-8",echo=False,max_overflow=5)

Base = declarative_base()

class Admin(Base):
    __tablename__ = "admin"
    id = Column(Integer, primary_key=True)
    username = Column(String(32))
    password = Column(String(64))

Base.metadata.create_all(engine)

Session_Class = sessionmaker(bind=engine) #建立與數據庫的會話，Session_Class爲一個類

Session = Session_Class() #實例化與數據庫的會話

t1 = Admin(username='test',password='123456') #生成admin表要插入的一條數據
t2 = Admin(username='test1',password='abcdef') #生成admin表要插入的一條數據

print(t1.username,t1.password)
print(t2.username,t2.password)

Session.add(t1) #把admin表要插入的數據添加到Session裏
Session.add(t2)

Session.commit() #提交，否則不能建立數據

運行結果

數據也建立成功