pymysql读取文件夹下所有txt文件

使用pymysql库可以连接并操作MySQL数据库，不能直接用于读取文件夹下的所有txt文件。若要实现该功能，需使用os模块。

首先，需要导入os模块:
import os

然后，定义一个函数来读取文件夹下的所有txt文件:
def read_txt_files(folder_path):
file_list = []
files = os.listdir(folder_path)
for file in files:
if file.endswith(".txt"):
file_list.append(file)
return file_list

在函数内部，使用os.listdir()函数获取指定文件夹中的所有文件名，然后使用.endswith()方法来检查文件是否以".txt"结尾，如果是，则将文件名添加到file_list列表中。最后，返回file_list列表，即所需的所有txt文件名。

使用该函数，可以通过传入文件夹路径来获取该文件夹下的所有txt文件。

示例代码如下：
folder_path = "文件夹路径"
txt_files = read_txt_files(folder_path)
for file in txt_files:
print(file)

其中，"文件夹路径"需要替换为实际的文件夹路径。运行代码后，即可打印出文件夹下的所有txt文件名。

相关问题

Python读取文件夹内新增文件内容上传数据库

可以使用Python的os模块和pymysql模块来实现。首先，使用os模块遍历文件夹内的文件，然后读取新增文件的内容，最后使用pymysql模块将内容上传到数据库中。以下是示例代码：

import os
import pymysql

# 遍历文件夹内的文件
folder_path = '/path/to/folder'
for filename in os.listdir(folder_path):
    file_path = os.path.join(folder_path, filename)
    if os.path.isfile(file_path):
        # 读取新增文件的内容
        with open(file_path, 'r') as f:
            content = f.read()

        # 将内容上传到数据库中
        conn = pymysql.connect(host='localhost', user='root', password='password', database='database')
        cursor = conn.cursor()
        sql = "INSERT INTO table_name (content) VALUES (%s)"
        cursor.execute(sql, content)
        conn.commit()
        cursor.close()
        conn.close()

注意，需要将`/path/to/folder`替换为实际的文件夹路径，将`localhost`、`root`、`password`、`database`、`table_name`替换为实际的数据库信息。

Python读取文件夹内新增内容上传数据库

可以使用Python的os模块和pymysql模块来实现。首先，使用os模块的listdir函数获取文件夹内的所有文件名，然后遍历每个文件，读取文件内容并将其插入到数据库中。具体代码如下：

import os
import pymysql

# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='password', database='test', charset='utf8')
cursor = conn.cursor()

# 文件夹路径
folder_path = '/path/to/folder'

# 获取文件夹内的所有文件名
file_names = os.listdir(folder_path)

# 遍历每个文件
for file_name in file_names:
    # 文件路径
    file_path = os.path.join(folder_path, file_name)
    # 读取文件内容
    with open(file_path, 'r', encoding='utf-8') as f:
        content = f.read()
    # 插入到数据库
    sql = "INSERT INTO table_name (content) VALUES (%s)"
    cursor.execute(sql, (content,))
    conn.commit()

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

其中，`/path/to/folder`需要替换为实际的文件夹路径，`test`需要替换为实际的数据库名，`table_name`需要替换为实际的表名。