本文主要給大家介紹，希望可以給大家補(bǔ)充和更新些知識(shí)，如有其它問題需要了解的可以持續(xù)在創(chuàng)新互聯(lián)行業(yè)資訊里面關(guān)注我的更新文章的。

創(chuàng)新互聯(lián)公司專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、巴州網(wǎng)絡(luò)推廣、成都小程序開發(fā)、巴州網(wǎng)絡(luò)營銷、巴州企業(yè)策劃、巴州品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營等，從售前售中售后，我們都將竭誠為您服務(wù)，您的肯定，是我們最大的嘉獎(jiǎng)；創(chuàng)新互聯(lián)公司為所有大學(xué)生創(chuàng)業(yè)者提供巴州建站搭建服務(wù)，24小時(shí)服務(wù)熱線：18980820575，官方網(wǎng)址：www.cdcxhl.com

PyMySQL 是在 Python3.x 版本中用于連接 MySQL 云服務(wù)器的一個(gè)庫，Python2中則使用mysqldb
話不多說，直接上代碼來說明用途

#!/user/bin/env python
#coding=utf-8

from pymysql import connect,cursors
from pymysql.err import OperationalError
import os
import configparser as cparser
from builtins import int
from framework.logger import Logger
import time

'''
========讀取config.ini文件中mysql配置========
'''
base_dir = str(os.path.dirname(os.path.dirname(file)))
file_path = base_dir + "\config\config.ini"

cf = configUtil(file_path)
host = cf.get("sitmysqlconf", "host")
port = cf.get("sitmysqlconf", 'port')
db = cf.get("sitmysqlconf", 'db_name')
user = cf.get("sitmysqlconf", 'user')
password = cf.get("sitmysqlconf", 'password')

logger = Logger(logger="mysqlUtils").getlog()

'''
===========封裝MySQL基本操作=============
'''
class mysqlUtils:

def __init__(self):
    '''
    初始化獲得mysql連接
    '''
    try:
        self.conn = connect(host=host,
                            port=int(port),
                            user=user,
                            password=password,
                            db=db,
                            charset='utf8mb4',
                            cursorclass=cursors.DictCursor
                            )
    except OperationalError as e:
        print (e)

def cursor(self):
    '''
    獲得游標(biāo)
    '''
    self.conn.cursor()

def getDict(self,tableName,systemID,ColumnNameKey,ColumnNameValue):
    '''
    公共方法，獲取id的字典
    '''
    with self.conn.cursor() as cursor:
        cursor.execute("select *  from %s WHERE system_id = %s and %s = %s",(tableName,systemID,ColumnNameKey,ColumnNameValue))
    Dict = cursor.fetchone()
    self.conn.commit()
    return Dict

    def AttentionLibraryDelete(self,system_id,merchant_id):
    '''非正常刪除數(shù)據(jù),即直接操作數(shù)據(jù)庫刪除'''
    with self.conn.cursor() as cursor:
        cursor.execute("delete  from tableName where system_id = %s and merchant_id = %s;",(system_id,merchant_id))
    self.conn.commit()

      def addMerchantTOIT(self,merchant_id):
    '''把商家關(guān)聯(lián)到XXX行業(yè)中'''
    #realSQL = "INSERT INTO tableName (system_id, merchant_id, business_id, status, creator_id, create_date, updater_id, update_date) VALUES ('7b6a99f3bce14915863cde5104bdf2c3', %s, '11', 'A', '8', unix_timestamp(now())*1000, '8', unix_timestamp(now())*1000);"  % repr(merchant_id)
    with self.conn.cursor() as cursor:
        cursor.execute("INSERT INTO t_sys_merchant_business (system_id, merchant_id, business_id, status, creator_id, create_date, updater_id, update_date) VALUES ('7b6a99f3bce14915863cde5104bdf2c3', %s, '11', 'A', '8', unix_timestamp(now())*1000, '8', unix_timestamp(now())*1000);",(merchant_id))
    self.conn.commit()
    logger.info('把商家【%s】關(guān)聯(lián)到xxx成功'%merchant_id)

def close(self):
'''
關(guān)閉mysql數(shù)據(jù)庫        
'''
self.conn.close()

看了以上關(guān)于Python2使用mysqldb講義，希望能給大家在實(shí)際運(yùn)用中帶來一定的幫助。本文由于篇幅有限，難免會(huì)有不足和需要補(bǔ)充的地方，如有需要更加專業(yè)的解答，可在官網(wǎng)聯(lián)系我們的24小時(shí)售前售后，隨時(shí)幫您解答問題的。