python同时读取数据库文件和电脑文件夹文件

python同时读取数据库文件和电脑文件夹文件,第1张

python同时读取数据文件和电脑文件夹文件

可以使用python的os模块和sqlite3模块来实现,具体实现步骤如下:

1 首先,使用python的os模块来获取电脑文件夹中的文件列表,如果文件夹中有子文件夹,可以使用oswalk()函数来获取文件夹中的文件列表;

2 然后,使用sqlite3模块来连接数据库文件,并使用sql语句来查询数据库中的数据;

3 最后,将查询出来的数据和文件夹中的文件列表进行合并,得到最终的数据。

python3下用flask-sqlalchemy对mysql数据库 *** 作案例:

from flask import Flask

from flaskextsqlalchemy import SQLAlchemy

app = Flask(__name__)

appconfig['SQLALCHEMY_DATABASE_URI'] = 'mysql://username:password@localhost/db_name'

db = SQLAlchemy(app)

class User(dbModel):

id = dbColumn(dbInteger, primary_key=True)

username = dbColumn(dbString(80), unique=True)

email = dbColumn(dbString(120), unique=True)

def __init__(self, username, email):

selfusername = username

selfemail = email

def __repr__(self):

return '<User %r>' % selfusername

admin = User('admin', 'admin@examplecom')

dbcreate_all() # In case user table doesn't exists already Else remove it

dbsessionadd(admin)

dbsessioncommit() # This is needed to write the changes to database

Userqueryall()

Userqueryfilter_by(username='admin')first()

增加一条数据

import pymysql

 

 #返回Connection对象

 #host="localhost"

 con = pymysqlconnect(host="1921683128",

                  port=3306,user="atguigu",

                  password="atguigu",

                  db="atguigudb",

                  charset="utf8")

 #返回cursor对象

 cursor = concursor()

 #SQL语言-SQL语句

 sql = "insert into students(name) value('李四')"

 #插入数据

 cursorexecute(sql)

 #提交数据,没有提交就没有数据

 concommit()

 #关闭释放资源

 cursorclose()

 #关闭资源

 conclose()

修改数据

import pymysql

 #修改任意一条数据

 

 #返回Connection对象

 conn = pymysqlconnect(

    host="1921683128",

    db="atguigudb",

    port=3306,

    user="atguigu",

    password="atguigu",

    charset="utf8"

 )

 cursor = conncursor()

 sql = "update students set name='郭靖' where id = 1"

 count = cursorexecute(sql)

 print("count=",count)

 #提交正常数据物理上修改了

 conncommit()

 cursorclose()

 connclose()

删除数据

import pymysql

 #修改任意一条数据

 

 #返回Connection对象

 conn = pymysqlconnect(

    host="1921683128",

    db="atguigudb",

    port=3306,

    user="atguigu",

    password="atguigu",

    charset="utf8"

 )

 cursor = conncursor()

 sql = "delete from students where id =20"

 count = cursorexecute(sql)

 print("count=",count)

 conncommit()

 cursorclose()

 connclose()

查询一条数据

import pymysql

 try:

    conn=pymysqlconnect(

       host='1921683128',

       port=3306,

       db='atguigudb',

       user='atguigu',

       passwd='atguigu',

       charset='utf8'

    )

    cursor=conncursor()

    cursorexecute('select  from students where id = 3')

    #返回满足这个条件的这个数据,如果有多条返回第一条,并且封装元组中

    result = cursorfetchone()

    print(result)

    for i in result:

       print(i)

    cursorclose()

    connclose()

 except Exception as e:

    print(emessage)

查询多条数据

import pymysql

 try:

    conn=pymysqlconnect(

       host='1921683128',

       port=3306,

       db='atguigudb',

       user='atguigu',

       passwd='atguigu',

       charset='utf8'

    )

    cursor=conncursor()

    cursorexecute('select  from students')

    #返回元组,如果多条数据,元组里面嵌套元组

    result = cursorfetchall()

    print(result)

    for i in result:

       print(i)

    conncommit()

    cursorclose()

    connclose()

 except Exception as e:

    print(emessage)

读取mysql数据,填写数据到excel

from pyexcel_xls import save_data

from pyexcel_xls import get_data

from collections import OrderedDict

import mysqlconnector

#和数据库建立连接

cnx =mysqlconnectorconnect(user='root', password='',  

                              host='127001',  

                              database='test')

#查询语句

sql = "select my_name,my_value from tbl_members "

#执行查询

cursorexecute(sql)

#获得查询结果

result = cursorfetchall()

cursorclose()

cnxclose()

#打开预定义表头文件

xls_header= get_data("d:/xhxls")

#获得表头数据

xh = xls_headerpop("Sheet1")

#拼接整表数据

xd = OrderedDict()

xdupdate({"Sheet 1":xh+result})

#保存到另一个文件中

save_data("d:/xdxls",xd)

可以使用Python的MySQL Connector来连接MySQL数据库,然后执行SQL查询语句。查询结果是一个结果集,每一行代表一个记录,可以使用for循环或者fetchone()函数来逐行遍历结果集,并对每一行进行处理。

以下是一个代码示例:

import mysqlconnector

# 连接数据库

cnx = mysqlconnectorconnect(user='your_username', password='your_password',

host='your_host', database='your_database')

# 创建游标

cursor = cnxcursor()

# 执行查询语句

query = "SELECT FROM your_table"

cursorexecute(query)

# 遍历结果集

for (column1, column2, column3) in cursor:

# 处理每一行

#

# 关闭游标和数据库连接

cursorclose()

cnxclose()

如果你想截取查询结果的一部分,可以在执行查询语句时使用LIMIT关键字来限制结果集的大小:

query = "SELECT FROM your_table LIMIT 10"

这样只会查询前10条记录。

以上就是关于python同时读取数据库文件和电脑文件夹文件全部的内容,包括:python同时读取数据库文件和电脑文件夹文件、python flask 在查询数据库数据时遇到错误unable to get repr for <class 'app.model.xx.xx’>怎么办呢、python使用数据库等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/sjk/9769204.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-05-01
下一篇2023-05-01

发表评论

登录后才能评论

评论列表(0条)

    保存