使用Python对Access读写操作

学习Python的过程中，我们会遇到Access的读写问题

一、可以利用win32.client模块的COM组件访问功能，通过ADODB操作Access的文件。

1、导入模块

import win32com.client

2、建立数据库连接

conn = win32com.client.Dispatch(r"ADODB.Connection")DSN = 'PROVIDER = Microsoft.Jet.OLEDB.4.0;DATA SOURCE = test.mdb'conn.Open(DSN)

3、打开一个记录集

rs = win32com.client.Dispatch(r'ADODB.Recordset')rs_name = 'MEETING_PAPER_INFO'rs.Open('[' + rs_name + ']', conn, 1, 3)

4、对记录集操作

rs.AddNew()  #添加一条新记录rs.Fields.Item(0).Value = "data"  #新记录的第一个字段设为"data"rs.Update()  #更新

5、用SQL语句来增、删、改数据

# 增sql = "Insert Into " rs_name + " (id, innerserial, mid) Values ('002133800088980002', 2, '21338')"  #sql语句conn.Execute(sql)  #执行sql语句# 删sql = "Delete * FROM " + rs_name + " where innerserial = 2"conn.Execute(sql)# 改sql = "Update " + rs_name + " Set mid = 2016 where innerserial = 3"conn.Execute(sql)

6、查：遍历记录

rs.MoveFirst()  #光标移到首条记录count = 0while True:    if rs.EOF:        break    else:        for i in range(rs.Fields.Count):            #字段名：字段内容            print(rs.Fields[i].Name, "：", rs.Fields[i].Value)        count += 1    rs.MoveNext()

7、关闭数据库

conn.Close()

二、利用pypyodbc模块

1.导入模块

import pypyodbc

2.建立数据库连接

#建立数据库连接def mdb_conn(db_name, password = ""):    """    功能：创建数据库连接    :param db_name: 数据库名称    :param db_name: 数据库密码，默认为空    :return: 返回数据库连接    """    str = 'Driver={Microsoft Access Driver (*.mdb)};PWD' + password + ";DBQ=" + db_name    conn = pypyodbc.win_connect_mdb(str)    return conn

3.创建游标

cur = conn.cursor()

4.用sql语句来增、删、改、查数据

#增def mdb_add(conn, cur, sql):    """    功能：向数据库插入数据    :param conn: 数据库连接    :param cur: 游标    :param sql: sql语句    :return: sql语句是否执行成功    """    try:        cur.execute(sql)        conn.commit()        return True    except:        return False#删def mdb_del(conn, cur, sql):    """    功能：向数据库删除数据    :param conn: 数据库连接    :param cur: 游标    :param sql: sql语句    :return: sql语句是否执行成功    """    try:        cur.execute(sql)        conn.commit()        return True    except:        return False#改def mdb_modi(conn, cur, sql):    """    功能：向数据库修改数据    :param conn: 数据库连接    :param cur: 游标    :param sql: sql语句    :return: sql语句是否执行成功    """    try:        cur.execute(sql)        conn.commit()        return True    except:        return False#查def mdb_sel(cur, sql):    """    功能：向数据库查询数据    :param cur: 游标    :param sql: sql语句    :return: 查询结果集    """    try:        cur.execute(sql)        return cur.fetchall()    except:        return []

5.关闭游标

cur.close()

6.关闭数据库连接

conn.close()

附：pypyodbc模块的完整测试代码

# -*- coding:utf-8 -*-__author__ = 'mayi'#导入模块import pypyodbc#定义conndef mdb_conn(db_name, password = ""):    """    功能：创建数据库连接    :param db_name: 数据库名称    :param db_name: 数据库密码，默认为空    :return: 返回数据库连接    """    str = 'Driver={Microsoft Access Driver (*.mdb)};PWD' + password + ";DBQ=" + db_name    conn = pypyodbc.win_connect_mdb(str)    return conn#增加记录def mdb_add(conn, cur, sql):    """    功能：向数据库插入数据    :param conn: 数据库连接    :param cur: 游标    :param sql: sql语句    :return: sql语句是否执行成功    """    try:        cur.execute(sql)        conn.commit()        return True    except:        return False#删除记录def mdb_del(conn, cur, sql):    """    功能：向数据库删除数据    :param conn: 数据库连接    :param cur: 游标    :param sql: sql语句    :return: sql语句是否执行成功    """    try:        cur.execute(sql)        conn.commit()        return True    except:        return False#修改记录def mdb_modi(conn, cur, sql):    """    功能：向数据库修改数据    :param conn: 数据库连接    :param cur: 游标    :param sql: sql语句    :return: sql语句是否执行成功    """    try:        cur.execute(sql)        conn.commit()        return True    except:        return False#查询记录def mdb_sel(cur, sql):    """    功能：向数据库查询数据    :param cur: 游标    :param sql: sql语句    :return: 查询结果集    """    try:        cur.execute(sql)        return cur.fetchall()    except:        return []if __name__ == '__main__':    pathfile = 'test.mdb'    tablename = 'prov'    conn = mdb_conn(pathfile)    cur = conn.cursor()    #增    sql = "Insert Into " + tablename + " Values (33, 12, '天津', 0)"    if mdb_add(conn, cur, sql):       print("插入成功！")    else:       print("插入失败！")    #删    sql = "Delete * FROM " + tablename + " where id = 32"    if mdb_del(conn, cur, sql):       print("删除成功！")    else:       print("删除失败！")    #改    sql = "Update " + tablename + " Set IsFullName = 1 where ID = 33"    if mdb_modi(conn, cur, sql):       print("修改成功！")    else:       print("修改失败！")    #查    sql = "SELECT * FROM " + tablename + " where id > 10"    sel_data = mdb_sel(cur, sql)    print(sel_data)    cur.close()    #关闭游标    conn.close()   #关闭数据库连接