常用python编程模板汇总
在我们编程时,有一些代码是固定的,例如Socket连接的代码,读取文件内容的代码,一般情况下我都是到网上搜一下然后直接粘贴下来改一改,当然如果你能自己记住所有的代码那更厉害,但是自己写毕竟不如粘贴来的快,而且自己写的代码还要测试,而一段经过测试的代码则可以多次使用,所以这里我就自己总结了一下python中常用的编程模板,如果还有哪些漏掉了请大家及时补充哈。 一、读写文件 1、读文件 (1)、一次性读取全部内容 filepath='D:/data.txt' #文件路径 with open(filepath,'r') as f: print f.read() (2)读取固定字节大小 # -*- coding: UTF-8 -*- filepath='D:/data.txt' #文件路径 f = open(filepath,'r') content="" try: while True: chunk = f.read(8) if not chunk: break content+=chunk finally: f.close() print content (3)每次读取一行 # -*- coding: UTF-8 -*- filepath='D:/data.txt' #文件路径 f = open(filepath,"r") content="" try: while True: line = f.readline() if not line: break content+=line finally: f.close() print content (4)一次读取所有的行 # -*- coding: UTF-8 -*- filepath='D:/data.txt' #文件路径 with open(filepath,"r") as f: txt_list = f.readlines() for i in txt_list: print i, 2、写文件 # -*- coding: UTF-8 -*- filepath='D:/data1.txt' #文件路径 with open(filepath,"w") as f: #w会覆盖原来的文件,a会在文件末尾追加 f.write('1234') 二、连接Mysql数据库 1、连接 #!/usr/bin/python # -*- coding: UTF-8 -*- import MySQLdb DB_URL='localhost' USER_NAME='root' PASSWD='1234' DB_NAME='test' # 打开数据库连接 db = MySQLdb.connect(DB_URL,USER_NAME,PASSWD,DB_NAME) # 使用cursor()方法获取操作游标 cursor = db.cursor() # 使用execute方法执行SQL语句 cursor.execute("SELECT VERSION()") # 使用 fetchone() 方法获取一条数据库。 data = cursor.fetchone() print "Database version : %s " % data # 关闭数据库连接 db.close() 2、创建表
3、插入 #!/usr/bin/python # -*- coding: UTF-8 -*- import MySQLdb # 打开数据库连接 db = MySQLdb.connect("localhost","TESTDB" ) # 使用cursor()方法获取操作游标 cursor = db.cursor() # SQL 插入语句 sql = """INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME,AGE,SEX,INCOME) VALUES ('Mac','Mohan',20,'M',2000)""" try: # 执行sql语句 cursor.execute(sql) # 提交到数据库执行 db.commit() except: # Rollback in case there is any error db.rollback() # 关闭数据库连接 db.close() 4、查询
5、更新 #!/usr/bin/python # -*- coding: UTF-8 -*- import MySQLdb # 打开数据库连接 db = MySQLdb.connect("localhost","TESTDB" ) # 使用cursor()方法获取操作游标 cursor = db.cursor() # SQL 更新语句 sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M') try: # 执行SQL语句 cursor.execute(sql) # 提交到数据库执行 db.commit() except: # 发生错误时回滚 db.rollback() # 关闭数据库连接 db.close() 三、Socket 1、服务器 from socket import * from time import ctime HOST = '' PORT = 21568 BUFSIZ = 1024 ADDR = (HOST,PORT) tcpSerSock = socket(AF_INET,SOCK_STREAM) tcpSerSock.bind(ADDR) tcpSerSock.listen(5) while True: print 'waiting for connection...' tcpCliSock,addr = tcpSerSock.accept() print '...connected from:',addr while True: try: data = tcpCliSock.recv(BUFSIZ) print '<',data tcpCliSock.send('[%s] %s' % (ctime(),data)) except: print 'disconnect from:',addr tcpCliSock.close() break tcpSerSock.close() 2、客户端 from socket import * HOST = 'localhost' PORT = 21568 BUFSIZ = 1024 ADDR = (HOST,PORT) tcpCliSock = socket(AF_INET,SOCK_STREAM) tcpCliSock.connect(ADDR) try: while True: data = raw_input('>') if data == 'close': break if not data: continue tcpCliSock.send(data) data = tcpCliSock.recv(BUFSIZ) print data except: tcpCliSock.close() 四、多线程 import time,threading # 新线程执行的代码: def loop(): print 'thread %s is running...' % threading.current_thread().name n = 0 while n < 5: n = n + 1 print 'thread %s >>> %s' % (threading.current_thread().name,n) time.sleep(1) print 'thread %s ended.' % threading.current_thread().name print 'thread %s is running...' % threading.current_thread().name t = threading.Thread(target=loop,name='LoopThread') t.start() t.join() print 'thread %s ended.' % threading.current_thread().name 还请大家积极补充! (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |