shenhp 发表于 2018-8-7 09:12:04

python环境测试MySQLdb、DBUtil、sqlobject性能

import MySQLdb  
from stockmining.stocks.setting import LoggerFactory
  
import connectionpool
  

  
class DBOperator(object):
  

  
    def __init__(self):
  
      self.logger = LoggerFactory.getLogger('DBOperator')
  
      self.conn = None
  

  
    def connDB(self):
  
      self.conn=MySQLdb.connect(host="127.0.0.1",user="root",passwd="root",db="pystock",port=3307,charset="utf8")
  
      #当需要使用连接池的时候开启
  
      #self.conn=connectionpool.pool.connection()
  
      return self.conn
  

  
    def closeDB(self):
  
      if(self.conn != None):
  
            self.conn.close()
  

  
    def execute(self, sql):
  
      try:
  
            if(self.conn != None):
  
                cursor = self.conn.cursor()
  
            else:
  
                raise MySQLdb.Error('No connection')
  

  
            n = cursor.execute(sql)
  
            return n
  
      except MySQLdb.Error,e:
  
            self.logger.error("Mysql Error %d: %s" % (e.args, e.args))
  

  
    def findBySQL(self, sql):
  
      try:
  
            if(self.conn != None):
  
                cursor = self.conn.cursor()
  
            else:
  
                raise MySQLdb.Error('No connection')
  

  
            cursor.execute(sql)
  
            rows = cursor.fetchall()
  
            return rows
  
      except MySQLdb.Error,e:
  
            self.logger.error("Mysql Error %d: %s" % (e.args, e.args))
页: [1]
查看完整版本: python环境测试MySQLdb、DBUtil、sqlobject性能