将Python Flask应用的数据库从MySQL Workbench迁移至SharePoint List

一、Python连接SharePoint List的可行方案 #

完全可以用Python对接SharePoint List，常用的两种实现方式：

• shareplum库：轻量易用，专门针对SharePoint List做了封装，适合快速实现CRUD操作。示例代码：

  from shareplum import Site
  from shareplum.site import Version
  
  # 初始化SharePoint站点连接（建议放在Flask app启动时完成）
  site = Site(
      "https://your-sharepoint-domain/sites/your-target-site",
      version=Version.v365,
      auth=("your-username", "your-password")  # 企业环境也支持应用权限认证
  )
  # 获取目标列表
  target_list = site.List("YourListName")
  # 查询列表数据
  items = target_list.GetListItems()
  

• Microsoft Graph API SDK：如果是Office 365企业环境，推荐使用这个方案，支持更复杂的权限控制、批量操作，功能覆盖更全面。

二、最小化修改原有MySQL代码的核心思路 #

要减少代码改动，关键是将数据访问逻辑与业务逻辑解耦，用统一接口封装底层操作，只替换实现而不修改业务代码。结合你提到的“类似MsSQL查询”需求，具体步骤如下：

1. 封装通用数据访问层（DAO）
   把原来直接用pymysql/SQLAlchemy编写的MySQL操作，全部封装成独立函数，比如get_records(filter_condition)、add_record(data)、update_record(data)等。业务代码仅调用这些函数，无需关心底层是MySQL还是SharePoint。

2. 用OData查询模拟SQL语法
   SharePoint List支持OData查询，语法与SQL高度接近，可直接映射原有MySQL查询逻辑：

   • 比如原有MySQL查询：SELECT id, username FROM users WHERE age > 18 AND status = 'active'
   • 对应SharePoint的OData查询写法：

     filtered_items = target_list.GetListItems(
         select=['ID', 'Username'],
         filter="Age gt 18 and Status eq 'active'"
     )
     

   你甚至可以写个简单的转换函数，把常用SQL片段（如WHERE、SELECT）转换成OData参数，让业务层的查询逻辑几乎不用修改。

3. 对齐数据字段结构
   SharePoint List返回的是字典列表，和MySQL查询返回的字典结构基本一致。只要保证SharePoint List的字段名（注意大小写）与原有MySQL表字段对应，业务层处理数据的代码可直接复用。比如原来取user['username']，现在只需转换键名适配：

   # 转换字段名以适配原有业务代码
   adapted_users = [{'id': item['ID'], 'username': item['Username']} for item in filtered_items]
   

4. 适配批量与事务操作
   SharePoint List无原生事务支持，可自行实现伪事务（比如批量操作前备份数据，失败后恢复）；批量插入/更新可使用UpdateListItems方法一次性处理多条数据，模拟MySQL的批量操作逻辑。

三、代码替换示例 #

原有MySQL数据访问代码 #

import pymysql

def get_active_users(min_age):
    conn = pymysql.connect(host='localhost', user='db-user', password='db-pass', db='app-db')
    cursor = conn.cursor(pymysql.cursors.DictCursor)
    cursor.execute("SELECT id, username FROM users WHERE age > %s AND status = 'active'", (min_age,))
    result = cursor.fetchall()
    conn.close()
    return result

替换后的SharePoint数据访问代码 #

from shareplum import Site
from shareplum.site import Version

# 全局初始化SharePoint连接（Flask中可放在app/__init__.py里）
site = Site(
    "https://your-sharepoint-domain/sites/your-site",
    version=Version.v365,
    auth=("sp-username", "sp-password")
)
users_list = site.List("AppUsers")

def get_active_users(min_age):
    # 用OData filter模拟原有SQL条件
    items = users_list.GetListItems(
        select=['ID', 'Username'],
        filter=f"Age gt {min_age} and Status eq 'active'"
    )
    # 转换字段名适配原有业务代码
    return [{'id': item['ID'], 'username': item['Username']} for item in items]

这样业务层调用get_active_users(18)的代码完全无需修改，仅替换了数据访问层的实现即可。

内容的提问来源于stack exchange，提问作者Irfan Mansoori