点击蓝字

关注我们

pip install SQLAlchemy

pip3 install SQLAlchemy‑1.2.15‑cp37‑cp37m‑win_amd64.whl

pip3 install pymysql

Python连接数据库之前，得先准备好MySQL数据库，由于篇幅问题这里不再说明软件下载和安装过程，请自行Google，只简单介绍环境配置，MySQL采用5.7.17GPL版本，数据库是本地数据库，端口为默认的3306，使用数据库名为test，如下图所示。

数据库准备妥当后，我们来一起看看Python是怎么连接的呢？这里给出连接代码：

from sqlalchemyimport create_engine as ce

engine = ce("mysql+pymysql://root:root@localhost:3306/test?charset=utf8",echo=True,pool_size=5,max_overflow=4,pool_recycle=7200,pool_timeout=30)

这里简单说明一下连接参数的含义吧，数据库类型+数据库接口模块://数据库用户名:密码@IP:端口号/数据库名；charset=utf-8是对数据库编码进行设置，以防读取中文时编码错误(这里先说明一下，要是字符类型写成utf-8创建表时铁定报错，需要写成charset=utf8)；echo=True用于显示SQLalchemy在操作数据库时所执行的SQL语句情况，相当于一个监视器，可以清楚的知道执行情况；pool_size=5为设置连接数，默认就是5，可根据实际情况调整，但一般开发中5个连接够用；max_overflow=4默认连接数为10，当超出最大连接数后，如果超出的连接数在max_overflow设置的访问内，超出的部分还可以继续连接访问，在使用过后，在使用过后，这部分连接不放在pool（连接池）中，而是被真正关闭；pool_recycle为连接重置周期，默认为-1，推荐设置为7200，即如果连接已空闲7200秒，就自动重新获取，以防止connection被关闭；pool_timeout为连接超时时间，默认为30秒，超过时间的连接都会连接失败。

创建数据库表

from sqlalchemy.ext.declarative import declarative_base

from sqlalchemy import Column,Integer,String,DateTime

Base = declarative_base()

class mytable(Base):

    __table__='mytable'

    #以下为字段和属性

    id = Column(Integer,primary_key=True)

    name = Column(String(50),unique=True)

    age = Column(Integer)

    birth = Column(DateTime)

    class_name = Column(String(50))

#创建数据表

Base.metadata.create_all(engine)

当执行创建数据表的命令时报错了，“ AttributeError: 'NoneType' object has no attribute 'encoding' ”看到这个应该是字符串的问题，一边去找报错的connections.py文件，一边去找度娘，发现是说提供的编码类型错误为【utf-8】而实际上编码应该是【utf8】，知道踩坑了，于是乎去检查，原来是数据库连接串中写为“charset=utf-8”，于是乎改掉连接串重新操作。

执行以上创建表语句则已经创建好了表”mytable”，打开MySQL，切换到test数据库，查询表如下图所示。

以上创建表由程序创建，也是比较常见的方式之一，下面有一种类似SQL语句的创建方法。

from sqlalchemy import Column, MetaData, ForeignKey, Table

from sqlalchemy.dialects.mysql import (INTEGER, CHAR)

meta = MetaData() myclass = Table('myclass',meta,             

Column('id', INTEGER,primary_key=True),                

Column('name', CHAR(50)),               

Column('class_name',CHAR(50))                           )

myclass.create(bind=engine)   #创建数据表

#删除数据表,删除表时先删除myclass然后删除mytable，因为myclass表中存在外键，必须先删除有外键的表才可以

myclass.drop(bind=engine)

但是当第二次使用上面语法创建时已经关闭了以上窗口，重新连接数据库，创建myclass表时会报错：“NameError: name 'mytable' is not defined”,无奈，只能重新执行上面步骤，却报错了“ AttributeError: 'str' object has no attribute 'c' ”，怀疑是自己环境问题，随之又使用了Anaconda安装了SQLAlchemy1.2.7，MySQL采用5.7.17，但是还是报错一样，这里贴图如下，希望有路过的大神斧正，不胜感激。网上找了好久，百思不得其解，于是乎又去换个环境，采用Ubuntu16.04，Python3.6.5安装MySQL5.7.13,SQLAlchemy1.2.15版本还是相同的报错，绝望中！

>>> from sqlalchemy import create_engine

>>> engine = create_engine("mysql+pymysql://root:root@localhost:3306/test?charset=utf8",echo=True,pool_size=5,max_overflow=4,pool_recycle=7200,pool_timeout=30)

>>>

>>> from sqlalchemy import Column, Integer, String, DateTime

>>> from sqlalchemy.ext.declarative import declarative_base

>>> Base = declarative_base()

>>>

>>> class mytable1(Base):

...     __table__= 'mytable1'

...

...     id = Column(Integer, primary_key=True)

...     name = Column(String(50), unique=True)

...     age = Column(Integer)

...     birth = Column(DateTime)

...     class_name = Column(String(50))

...

Traceback (most recent call last):

  File "<stdin>", line 1, in <module>

  File "C:\Users\Administrator\AppData\Local\Programs\Python\Python36\lib\site-packages\sqlalchemy\ext\declarative\api.py", line 65, in __init__

    _as_declarative(cls, classname, cls.__dict__)

  File "C:\Users\Administrator\AppData\Local\Programs\Python\Python36\lib\site-packages\sqlalchemy\ext\declarative\base.py", line 116, in _as_declarative

    _MapperConfig.setup_mapping(cls, classname, dict_)

  File "C:\Users\Administrator\AppData\Local\Programs\Python\Python36\lib\site-packages\sqlalchemy\ext\declarative\base.py", line 144, in setup_mapping

    cfg_cls(cls_, classname, dict_)

  File "C:\Users\Administrator\AppData\Local\Programs\Python\Python36\lib\site-packages\sqlalchemy\ext\declarative\base.py", line 172, in __init__

    self._setup_table()

  File "C:\Users\Administrator\AppData\Local\Programs\Python\Python36\lib\site-packages\sqlalchemy\ext\declarative\base.py", line 495, in _setup_table

    if not table.c.contains_column(c):

AttributeError: 'str' object has no attribute 'c'

>>>

后面猜测是SQLAlchemy包的问题，对此包掌握的不是很熟悉，故采用第二种建表方法，如下所示。

from sqlalchemy import Column, MetaData, DateTime, Table

from sqlalchemy.dialects.mysql import (INTEGER, CHAR)

meta = MetaData()

mytable = Table('mytable',meta,

                Column('id', INTEGER, primary_key=True),

                Column('name', CHAR(50)),

Column('age', INTEGER),

Column('birth',DateTime),

                Column('class_name', CHAR(50))            

                )

mytable.create(bind=engine) 

from sqlalchemy import Column, MetaData, ForeignKey, Table

from sqlalchemy.dialects.mysql import (INTEGER, CHAR)

meta = MetaData()

myclass = Table('myclass',meta,

                Column('id', INTEGER, primary_key=True),

                Column('name', CHAR(50)),

                Column('class_name', CHAR(50))            

                )

myclass.create(bind=engine)  

#CREATE TABLE myclass (id INTEGER NOT NULL AUTO_INCREMENT,name CHAR(50),class_name CHAR(50),PRIMARY KEY (id)

插入数据

当建立好表关系后，需要将数据插入到表中，对其进行相关的操作前，需要创建一个会话对象用于执行SQL语句，所用代码如下。

引入sessionmaker模块，指定绑定已连接数据库的engine对象，生成会话对象session，该对象用于数据库的增、删、改、查。那么创建表添加数据的语法如下。

new_data = mytab(name= ‘zhangdan’,age=7,birth=’2010-12-22’,class_name=‘class1’)

session.add(new_data)

session.commit

session.close()

update更新数据

session.query(mytable).filter_by(id= 1 ).update ({mytable.age:12})

session.commit

session.close()

查询数据

查询数据时，由于上表数据较少，先插入一些数据，方便内容展示

insert into myclass values(2,'xiaoxiao','class1');

insert into myclass values(3,'xiaoli','class2');

insert into myclass values(4,'xiaoma','class2');

insert into myclass values(5,'xiaowang','class1');

查询数据时，可查看全部数据，特定字段的数据以及条件查询数据

#查询全部数据

get_data = session.query(myclass).all()

print(get_data)

 

#查询特定字段数据

get_data =session.query(myclass.name,myclass.class_name).all()

print(get_data)

 

#按条件查询

get_data =session.query(myclass).filter_by(class_name='class1').all()

print('数据类型是：' + str(type(get_data)))

for i in get_data:

    print('Myname is :' + i.name)

    print('Myclass is :' + i.class_name)

好啦，关于SQLAlchemy和MySQL就说这么多了，使用SQLAlchemy过程中可算是遇到了数不清的坑，而且花费两周末都是找不到原因，可怕的是第一次可以，第二次就报错，着实是让我无解，结尾也会放置采坑过程中的链接，供大家参考。对SQLAlchemy框架不熟悉的建议还是使用标准的API接口来连接数据库比较好，那么下面就继续说说使用python来操作Oracle数据库。

通过CMD查看监听状态也是已经启动，使用sqlplus连接到数据库，也可使用工具PLSQL远程连接，需要注意监听状态是否正常以及监听端口是否为默认的1521。

pip3 install cx_Oracle

--查看安装版本

>>> import cx_Oracle

>>> cx_Oracle.__version__

'7.0.0'

创建数据库连接connect和关闭数据库连接close

创建数据库连接的三种方式：

方法一：用户名、密码和监听分开写

import cx_Oracle

db=cx_Oracle.connect('username/password@host:port/orcl')

db.close()

方法二：用户名、密码和监听写在一起

import cx_Oracle

db=cx_Oracle.connect('username','password','host:1521/orcl')

db.close()

方法三：配置监听并连接

import cx_Oracle

tns=cx_Oracle.makedsn('host',1521,'orcl')

db=cx_Oracle.connect('username','password',tns)

db.close()

查询数据

import cx_Oracle

#连接数据库

db = cx_Oracle.connect('scott/scott@localhost:1521/orcl')

#打开游标

cur = db.cursor()

#执行SQL

sql = " select sysdate from dual"

cur.execute(sql)

data = cur.fetchone()

print('Database time:%s' % data)

#提交、关闭游标

cur.close()

db.close()

创建数据库表并插入数据

db = cx_Oracle.connect('scott/scott@localhost:1521/orcl')

cur = db.cursor()

cur.execute ("CREATE TABLE my_job(id INT, name VARCHAR(40), age INT, job VARCHAR(50))") 

cur.execute ("INSERT INTO my_job (id, name, age)VALUES(12,'xiaoliu', 32)") 

cur.execute ("INSERT INTO my_job (id, name, age)VALUES(13,'xiaoli', 23)") 

cur.execute ("INSERT INTO my_job (id, name, age,job)VALUES(14,'xiaoma',36,'IT')") 

cur.execute ("INSERT INTO my_job VALUES(15,'xiaocai',36,'worker')")

db.commit() #这里一定要commit才行，要不然数据是不会插入的

cur.execute("SELECT * FROM my_job")

# 提取一条数据，返回一个元祖

data = cur.fetchone()

print(data)

cur.close()

db.close()

删除数据并查询

#删除数据

db = cx_Oracle.connect('scott/scott@localhost:1521/orcl')

cur = db.cursor()

cur.execute ("delete from my_job where id=12")

db.commit()

cur.execute("SELECT * FROM my_job")

rows = cur.fetchall()

for row in rows:

       print("%d, %s, %d, %s" % (row[0], row[1], row[2], row[3]))

cur.close()

db.close()

utf8错误参考：https://blog.csdn.net/zlsdmx/article/details/84836240

SQLAlchemy框架错误：https://stackoverflow.com/questions/48473140/sqlalchemy-exc-noreferencedtableerror-foreign-key-associated-with-column-x-coul

https://stackoverflow.com/questions/45845007/python-sqlalchemy-getting-table-object-is-not-callable-error

ORM框架：https://www.cnblogs.com/pycode/p/mysql-orm.html

Windows环境下基于Anaconda的Python3安装

使用Python爬取《悲伤逆流成河》猫眼信息

欢迎关注此公众号，写作不易，您的关注与点赞将是我不断写作的动力，点击最上方蓝字关注我吧！如果觉得此文对您有帮助，欢迎点赞、分享、转发！