Python处理数据库

时间：2024-12-27 13:35:02
  • 使用数据库驱动连接数据库 （Connection对象）
  • 打开游标（Cursor对象），并通过它执行SQL语句（execute方法）
  • 提交操作（commit()）
  • 关闭连接（close()）
  • ORM将表记录映射为对象

1,SQLite

　　Python内置了SQLite3，查看sqlite3文档

import sqlite3

conn = sqlite3.connect('数据库.db')

cur = conn.cursor()

# 建表

cur.execute('create table user '

            '(id varchar(20) primary key, name varchar(20), password varchar(20))')

# 插值

cur.execute('INSERT INTO user values("1","April","1234567890")')

# 提交

conn.commit()

# 关闭连接

conn.close()

　　note! 当SQL语句需要使用到Python程序中的变量值时，不要使用Python中字符串操作来组合查询，因为这样容易受到SQL注入攻击。解决方法是使用DB-API的参数替代：用？作为占位符，然后提供 值的元组 作为游标execute()方法的第二个参数。 （其他数据库模块可能使用不同的占位符，例如％s 或：1）。

import sqlite3

conn = sqlite3.connect("数据库.db")

cur = conn.cursor()

name = 'April'

# SQL语句中使用Python程序中的变量时

# Never do this -- insecure!

#cur.execute("SELECT * FROM user WHERE name = '%s'" % name)

# Do this instead

t = ('April',)

cur.execute('SELECT * FROM user WHERE name=?', t)

print(cur.fetchone())

# 用for循环获取execute()查找返回的结果【还有fetchone()/fetchall()等方法】

for row in cur.execute('select * from user'):

    print(row)

cur.execute('select "name","password" from user where id=?', ('',))

print(cur.fetchall())

print(cur.rowcount) # rowcount表示上一操作影响的行数,-1表示该游标未执行语句或者接口未确定最后一个操作的行数

try:

    # Larger example that inserts many records at a time

    users = [('', 'A', ''),

                 ('', 'B', ''),

                 ('', 'C', ''),

                ]

    cur.executemany('INSERT INTO user VALUES (?,?,?)', users)

except sqlite3.IntegrityError as e:

    print('插入失败:',e)

finally:

    conn.commit()

    conn.close()

2，MySQL

　　安装：注意设置root密码不要忘记，以后连接数据库时要使用哦

　　修改MySQL数据库默认数据存储的位置：将 C:\ProgramData\MySQL\MySQL Server 5.7 中 my.ini文件的 " datadir =... " 修改为目标路径，注意ProgramData文件夹是被隐藏的

  • 在实验室电脑上安装MySQL时，配置到starting server时卡住了，重装好几次都是这样。 在开始菜单里无法打开MySQL Command Line Client.最后查阅网上资料，解决方法如下：

　　cmd命令下进入MySQL安装目录（C:\Program Files\MySQL\MySQL Server 5.7\bin），输 入 mysql -u root -p ，出现Enter Password,这时不用输入密码，直接回车便进入了

MySQL数据库。

　　后来查看安装日志（C:\ProgramData\MySQL\MySQL Installer for Windows\Logs），发现出现  mysql-installer Information: 10 : 2017-10-17T07:07:38.244359Z 1 [Warning]
root@localhost is created with an empty password ! Please consider switching off the --initialize-insecure option. 不知是否有关。
　　更改root密码：set password for root@localhost = password('password');

　　问题是以后都得这样登录Mysql太繁琐

　　MySQL语句：http://www.cnblogs.com/picaso/archive/2012/05/17/2505895.html

　　

Python连接Mysql

　　安装MySQL数据库驱动（MySQL driver） pip install mysql-connector（mysql.connector模块），若失败，可安装pip install mysql-connector==2.1.4；或者安装 pymysql

pip install PyMySql （PyMySql模块）;

　　具体连接数据库以及各种操作与SQLite相似;

　　https://dev.mysql.com/doc/connector-python/en/connector-python-example-connecting.html

使用mysql.connector:

import mysql.connector

from mysql.connector import errorcode

conn = mysql.connector.connect(user = 'root',password = 'password', host = '127.0.0.1', database = 'test')

cur = conn.cursor()

# 建表

try:

    cur.execute('create table teacher (id varchar(20) primary key, name varchar(20))')

except mysql.connector.Error as err:

    if err.errno == errorcode.ER_TABLE_EXISTS_ERROR:

        print('already exists!')

    else:

        print(err.msg)

else:

    print('建表成功！')

cur.close()

conn.close()

使用pymysql:

import pymysql

conn = pymysql.connect(user = 'root',password = 'password', host = '127.0.0.1', database = 'test')

# 建表

try:

    with conn.cursor() as cur:  #相当于cur = conn.cursor 打开游标，不用再去关闭

        # Create a new record

        sql = "INSERT INTO teacher (id, name) VALUES (%s, %s)"

        cur.execute(sql , ('', 'EE'))

    # connection is not autocommit by default. So you must commit to save

    # your changes.

    conn.commit()

except:

    pass

try:

    with conn.cursor() as cur:

        # Read a single record

        sql = "SELECT id,name FROM teacher WHERE id = %s"

        cur.execute(sql, ('',))

        result = cur.fetchone()

        print(result)

except:

    pass

finally:

    conn.close()

3, ORM   Object-Relational Mapping，把关系数据库的表结构映射到对象上

　　ORM框架：把数据库的一行转化为程序中的一个对象，安装SQLAlchemy模块，pip install SQLALchemy

　　Python的DB-API返回的表数据结构为 一个包含tuple的list，每个tuple表示表的一行记录；ORM就是将这样的一个tuple表示为一个class的实例，将一张表转化为一个类。所以向表中插入一行就相当于添加一个对应的对象。

　　

from sqlalchemy import Column,String,create_engine

from sqlalchemy.orm import sessionmaker

from sqlalchemy.ext.declarative import declarative_base

# 创建对象基类

Base = declarative_base()

class Teacher(Base):

    # 表名

    __tablename__ = 'teacher'

    # 表结构

    id = Column(String(20), primary_key=True)

    name = Column(String(20))

# 初始化数据库连接:

engine = create_engine('mysql+mysqlconnector://root:password@localhost:3306/test')

# 创建DBSession类型:

DBSession = sessionmaker(bind=engine)

# 添加记录（把对象添加到session）

session = DBSession()  # DBSession对象可视为当前数据库连接

new_teacher = Teacher(id= '', name ='Anna')

session.add(new_teacher)

session.commit()

session.close()

# 查询记录

session = DBSession()

# 创建Query查询，filter是where条件，最后调用one()返回唯一行，如果调用all()则返回所有行:

user = session.query(Teacher).filter(Teacher.id=='').one()

print('type:', type(user))

print('name:', user.name)

session.close()

　　

　　

相关文章