因為鏈接數據庫的方式比較固定,所以我們把它封裝成一個函數,以后用的時候,直接copy就OK了,代碼如下:
import pymysql mysql_info = { "host":"110.10.**.**",#數據庫IP "user":"jxz",#數據庫用戶名 "passwd":"****",#密碼 "db":"jxz",#要連接的數據名字 "port":3306, "charset":"utf8",#字符集 "autocommit":True } def execute_sql(sql,all=True,cur_type=1): #cur_type如果是1,那么返回的是list #如果是2,那么返回的字典 connect = pymysql.connect(**mysql_info)#鏈接數據庫 cur = connect.cursor() if cur_type == 1 else connect.cursor(pymysql.cursors.DictCursor)# 使用 cursor() 方法創建一個游標對象 cursor,指定成字典形式 cur.execute(sql)# 執行sql語句 if all: result = cur.fetchall()#顯示全部查詢結果,輸出形式為二維數組 else: result = cur.fetchone()#執行一條,輸出形式為list cur.close()#關閉游標 connect.close()#關閉數據庫 return result
這個看着要是比較難,我們還有容易看懂的連接方式哦……
import pymysql #程序包含的模塊 db = pymysql.connect(host='110.40.**.**',user='jxz',password='123456',database='jxz')#連接數據庫 cur = db.cursor() # 使用 cursor() 方法創建一個游標對象 cursor sql="select * from student_info where name='某某'"%uname cur.execute(sql)#執行sql db.commit()#記得一定要提交 cur.close()#關閉游標哦 db.close()#關閉數據庫
執行后數據庫中應該會新增一條數據