import cx_Oracle def sql_comm(sql_run): db = cx_Oracle.connect(‘user’, ‘passwd’, ‘IP:port/sid’) try: cursor=db.cursor() except cx_Oracle.ERROR,e: print “Error %d:%s”%(e.args[0],e.args[1]) try: cursor.execute(sql_run) result_set=cursor.fetchall() cursor.close() db.commit() db.close() return result_set except e: print “Error %s”%(e.args[0]) cursor.close() db.close()
python连接mysql
import MySQLdb def sql_comm(sql_run): try: conn=MySQLdb.connect(host=host,user=username,passwd=pwd,db=database) cursor = conn.cursor() except MySQLdb.Error,e: print “Error %d:%s”%(e.args[0],e.args[1]) try: cursor.execute(sql_run) result_set=cursor.fetchall() cursor.close() db.close() return result_set except MySQLdb.Error,e: print “Error %d:%s”%(e.args[0],e.args[1]) cursor.close() db.close()
注意部分,在mysql修改数据时最好使用commit,如果只是select就不用了,不然得不到数据。
在oracle和mysql插入大量数据时,可以使用executemany,需要注意的是,oracle插入大量
数据时要将数据类型为元组,然后放到列表中。建议一次插入10000行。
发表评论