Python

Mysql数据库链接:pymysql库

LensNews

查询

import pymysql #导入库
'''
打开数据库链接,获取链接对象
参数依次是:数据库地址,数据库用户名,数据库密码,数据库名
'''
dbcon=pymysql.connect('localhost','root','root','search_data')

# 使用 cursor() 方法创建一个游标对象 cursor
cursor=dbcon.cursor()

# 使用 execute()  方法执行 SQL 查询
cursor.execute('select * from words limit 20')

#使用fetchall()方法获取所有的查询结果,返回值为一个tup,其中只获取单条可以用使用fetchone(),多条使用fetchmany()
result=cursor.fetchall()

#遍历结果集
for x in  result:
    print(x)
dbcon.close()

------------------------------
"D:\Python Code\venv\Scripts\python.exe" "D:/Python Code/MyfirestPython.py"
(1, '关键词', None, None, None, None, None, None, None, None, None, 360, None, None, None)
(2, '电视墙装修效果图大全', None, 13339, 13115, 50, 9, 700, 20001, 5150000, None, None, 1083, None, None)
(3, '装修效果图', None, 10662, 8792, 100, 9, 8500, 20001, 14200000, None, 55963, 402495, None, None)
(4, '装修', None, 7123, 4824, 117, 15, 6900, 14700, 63000000, None, 1164, 2437089, None, None)
(5, '客厅装修效果图', None, 6620, 6256, 61, 22, 430, 15500, 11600000, None, 315, 19782, None, None)
(6, '厨房装修效果图', None, 6200, 5300, 58, 15, 2100, 10500, 9200000, None, 2423, 8384, None, None)
(7, '卫生间装修效果图', None, 5116, 4273, 31, 17, 1700, 9100, 11200000, None, 0, 4585, None, None)
(8, '客厅装修', None, 4745, 4186, 117, 12, 2400, 9400, 16800000, None, 7711, 77551, None, None)
(9, '卧室装修效果图', None, 4395, 3986, 69, 16, 410, 7800, 11300000, None, 0, 12538, None, None)
(10, '60平米小户型装修效果图', None, 4171, 4136, 67, 9, 10, 1300, 6190000, None, None, 14, None, None)

Process finished with exit code 0


创建表

import  pymysql

#获取数据库里链接对象
mydb=pymysql.connect('localhost','root','root','search_data')
#创建游标对象
cursor=mydb.cursor()
#execute()方法执行sql,如果表存在则删除
cursor.execute('drop table  if exists test1 ')
#创建表的sql
sql="""Create table test1(
        id int(11),
        name  varchar(21)) """

cursor.execute(sql)
#关闭数据库链接
mydb.close()

插入

import pymysql
#打开数据库链接
mydb=pymysql.connect('localhost','root','root','search_data')
#获取游标
cursor=mydb.cursor()
#预处理SQL语句
sql="""
    insert into test1(id,name) values(2,'小明');
    """
#DML语句必须捕获异常
try:
    #执行sql
    row=cursor.execute(sql)
    #将执行结果提交到数据库有
    mydb.commit()
    print('执行成功',row,'')
except:
    #如果执行失败则回滚
    mydb.rollback()
    print('执行失败,回滚')
mydb.close()#关闭数据库链接

删除

import pymysql
#打开链接
mydb=pymysql.connect('localhost','root','root','search_data')
#获取游标
cursor=mydb.cursor()
#预览sql
sql="""
    delete from test1 ;
    """
#捕获异常
try:
    #执行sql
    row=cursor.execute(sql)
    #提交到数据库
    mydb.commit()
    print('执行成功',row,'')
except:
    #执行失败则回滚
    mydb.rollback()
    print('执行失败')
#关闭链接
mydb.close()

修改操作

import pymysql
#链接数据库
mydb=pymysql.connect('localhost','root','root','search_data')
#获取游标
cursor=mydb.cursor()
#拼接sql
sql="""
    update  test1 set id=3,name='小张' where id=2
    """
#捕获异常
try:
    #执行sql
    row=cursor.execute(sql)
    #提交到数据库
    mydb.commit()
    print('执行成功',row,'')
except:
    #失败回滚
    mydb.rollback()
    print('执行失败')
#关闭数据库链接
mydb.close()

2019-06-09

(0)

本文由 SilenceLee的学习笔记 作者:silencelee 发表,转载请注明来源!

LensNews

热评文章

发表回复