如何递归检查目录与子目录内容，复制至新位置并同步数据库条目？

针对你的需求，下面用Python给出具体实现步骤和代码示例，适合编程新手理解：

1. 判断路径是否为目录 #

用pathlib模块（Python 3.4+推荐）可以快速判断目标路径类型：

from pathlib import Path

target_path = Path("/your/source/path")
if target_path.is_dir():
    print(f"{target_path} 是目录，开始处理")
    # 执行后续操作
else:
    print(f"{target_path} 不是目录，终止操作")

2. 递归遍历目录内所有内容 #

用os.walk可以递归遍历目录下的所有文件和子目录，返回当前目录路径、子目录列表、文件列表：

import os

source_dir = "/your/source/path"
for root, dirs, files in os.walk(source_dir):
    # root：当前遍历的目录路径
    # dirs：当前目录下的子目录列表
    # files：当前目录下的文件列表
    print(f"当前目录：{root}")
    print(f"子目录：{dirs}")
    print(f"文件：{files}")

3. 保留目录结构复制到目标位置 #

遍历过程中先创建对应目标目录结构，再复制文件，确保原结构完整保留：

import shutil

source_dir = "/your/source/path"
target_root = "/your/target/path"

for root, dirs, files in os.walk(source_dir):
    # 计算目标目录的相对路径
    relative_path = os.path.relpath(root, source_dir)
    target_dir = os.path.join(target_root, relative_path)
    
    # 创建目标目录（不存在则自动创建）
    os.makedirs(target_dir, exist_ok=True)
    
    # 复制当前目录下的所有文件
    for file in files:
        source_file = os.path.join(root, file)
        target_file = os.path.join(target_dir, file)
        # copy2会保留文件元数据（创建时间、修改时间等）
        shutil.copy2(source_file, target_file)

4. 同步数据库条目到新表 #

假设你使用SQLite数据库，原表名为file_metadata，新表名为copied_file_metadata，字段包含file_path、item_type（'dir'或'file'）、create_time，同步逻辑示例如下：

import sqlite3

# 连接数据库
conn = sqlite3.connect("your_database.db")
cursor = conn.cursor()

source_dir = "/your/source/path"
target_root = "/your/target/path"

def sync_db_record(source_path, item_type):
    # 查询原表中的对应条目
    cursor.execute("SELECT file_path, create_time FROM file_metadata WHERE file_path = ?", (source_path,))
    record = cursor.fetchone()
    if record:
        # 计算目标路径
        relative_path = os.path.relpath(source_path, source_dir)
        target_path = os.path.join(target_root, relative_path)
        # 插入新表
        cursor.execute("""
            INSERT INTO copied_file_metadata (file_path, item_type, create_time)
            VALUES (?, ?, ?)
        """, (target_path, item_type, record[1]))
        conn.commit()

# 遍历过程中同步目录和文件的数据库条目
for root, dirs, files in os.walk(source_dir):
    sync_db_record(root, "dir")
    for file in files:
        source_file = os.path.join(root, file)
        sync_db_record(source_file, "file")

# 关闭数据库连接
conn.close()

注意事项 #

• 替换代码中的路径、数据库路径和表结构为你实际的信息。
• 如果使用MySQL、PostgreSQL等其他数据库，只需调整数据库连接和SQL语句部分，核心逻辑一致。
• 处理大量文件或大文件时，建议添加try-except异常捕获，避免程序意外中断。

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