def sql_select(fileIn,fileOut): conn = sqlite3.connect(fileIn) cursorObj = conn.cursor() #定义游标 cursorObj.execute('SELECT Longitude,Latitude,PSJD,TBBH FROM FJ JOIN TBJBXX ON TBJBXX.BSM=FJ.TBBSM ') #从FJ表中查询经纬度数据 result = cursorObj.fetchall() #检索查询数据 with open(fileOut, 'w',newline='') as fp: writer = csv.writer(fp) writer.writerows(result) cursorObj.close() #关闭游标 conn.close() #关闭数据库链接
时间: 2024-04-11 18:32:41 浏览: 92
test_fileout.rar_c6713 flash
这段代码是一个函数,用于从一个 SQLite 数据库文件中查询数据,然后将查询结果写入到一个 CSV 文件中。函数的参数 `fileIn` 是输入的 SQLite 数据库文件名,`fileOut` 是输出的 CSV 文件名。
函数首先使用 `sqlite3.connect()` 方法连接到 SQLite 数据库,并创建一个游标对象 `cursorObj`。然后,使用 `cursorObj.execute()` 方法执行一个 SQL 查询语句,查询 `FJ` 表与 `TBJBXX` 表的连接结果中的经度、纬度、PSJD 和 TBBH 字段。查询结果通过 `cursorObj.fetchall()` 方法获取。
接下来,函数利用 `open()` 函数打开输出的 CSV 文件,使用 `csv.writer()` 方法创建一个写入器对象 `writer`,然后使用 `writer.writerows()` 方法将查询结果写入到 CSV 文件中。
最后,函数关闭游标和数据库连接,释放资源。
请问您还有其他问题吗?
阅读全文