链接sql数据库并输出csv文件
2023-09-11 14:17:15 时间
__author__ = 'chunyang.wu' #作者:SelectDB # -*- coding: utf-8 -*- import MySQLdb import os os.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8' import sys reload(sys) sys.setdefaultencoding('utf-8') import csv class Handle(): def __init_db(self): self._mysql_db = MySQLdb.connect(host="172.16.1.55",user="test",passwd="123456",port=3306,db="test",unix_socket="/tmp/mysql5.sock") self.mysql_cur=self._mysql_db.cursor() self.seq = 0 def __init__(self): self.__init_db() def _release_db(self): self.mysql_cur.close() self._mysql_db.close() def _do(self): self.mysql_cur.arraysize = 50 select_sql = "SELECT id,email,FROM_UNIXTIME(create_time) AS create_time FROM test.tbl_member " print select_sql self.mysql_cur.execute(select_sql) count = 0 csvfile = file('all_user.csv', 'wb') print dir(csv) writers = csv.writer(csvfile) writers.writerow(['uid', 'email', 'createtime']) while 1: lines = self.mysql_cur.fetchmany(50) if len(lines)==0: break for i in lines: print i writers.writerows([i]) csvfile.close() def main(): p = Handle() p._do() p._release_db() if __name__=="__main__": main()
相关文章
- PHP ~ 通过程序删除图片,同时删除数据库中的图片数据 和 图片文件
- [翻译]为什么你不要收缩数据库文件
- MySql通过数据库文件恢复数据库
- mysql 数据库通过拷贝文件恢复方法
- c++--------获取某个路径下所有文件的文件名,读写TXT文件到新的文件
- 创建基于文件组的数据库SQL救命语句
- C#各种扩展名文件存入sql server数据库及读取到本地文件
- 转海量小文件存储与Ceph实践
- R语言︱文件读入、读出一些方法罗列(批量xlsx文件、数据库、文本txt、文件夹)
- 大叔问题定位分享(20)hdfs文件create写入正常,append写入报错
- 一种文件恢复技巧
- 用Powershell调用DLL文件
- 利用PHP执行SQL文件,将SQL文件导入到数据库【转】
- golang文件操作:打开关闭文件,带缓冲区的读文件
- Windows Server 2008 显示隐藏文件 扩展名
- ASP.NET Core 1.0中实现文件上传的两种方式(提交表单和采用AJAX)
- 如何使用 ABAP 代码解析 XML 文件试读版
- 天龙八部TLBB系列 - 网单服务端Public/Data目录文件说明
- 〖Python 数据库开发实战 - Python与MySQL交互篇⑩〗- 创建新闻管理系统的具体python文件
- 教你如何将二进制文件导入到数据库
- 【java项目实战】dom4j解析xml文件,连接Oracle数据库
- Linux 下使用 ffmpeg 大批量合并 ts 文件, mp4切割文件为m3u8
- 统计Oracle数据库文件的大小
- FileReader读取文件里文乱码问题
- hibernate.cfg.xml文件的配置模板和不同数据库的配置參数
- 10.2 gzip--支持操作gzip文件库
- c# 给文件/文件夹 管理用户权限
- dump文件类型与dump文件生成方法详解
- 转 Django根据现有数据库,自动生成models模型文件
- 【数据库管理】③控制文件