首页 > 数据库 >Pymysql增删改查

Pymysql增删改查

时间:2022-09-18 21:02:05浏览次数:205  
标签:__ name 改查 Pymysql cursor pymysql 增删 main con

1、mysql
DDL(数据定义语言)、DML(数据操作语言)和DCL(数据控制语言)

查看服务器版本
select version();

查看所有数据库。
show databases;

切换到指定数据库。
use mysql;

查看数据库下所有表。
show tables;

安装PyMySQL。
pip install pymysql

import pymysql

#添加数据
def main():
no = int(input('编号: '))
name = input('名字: ')
loc = input('所在地: ')
# 1. 创建数据库连接对象
con = pymysql.connect(host='localhost', port=3306,
      database='hrs', charset='utf8',
      user='yourname', password='yourpass')
try:
# 2. 通过连接对象获取游标
    with con.cursor() as cursor:
# 3. 通过游标执行SQL并获得执行结果
         result = cursor.execute(
        'insert into tb_dept values (%s, %s, %s)',
         (no, name, loc)
         )
        if result == 1:
          print('添加成功!')
# 4. 操作成功提交事务
     con.commit()
finally:
# 5. 关闭连接释放资源
     con.close()


if __name__ == '__main__':
main()


#删除数据
import pymysql
def main():
no = int(input('编号: '))
con = pymysql.connect(host='localhost', port=3306,
        database='hrs', charset='utf8',
        user='yourname', password='yourpass',
        autocommit=True)
try:
    with con.cursor() as cursor:
        result = cursor.execute(
        'delete from tb_dept where dno=%s',
        (no, )
        )
        if result == 1:
            print('删除成功!')
finally:
        con.close()


if __name__ == '__main__':
    main()


#更新数据
import pymysql
def main():
no = int(input('编号: '))
name = input('名字: ')
loc = input('所在地: ')
con = pymysql.connect(host='localhost', port=3306,
        database='hrs', charset='utf8',
        user='yourname', password='yourpass',
        autocommit=True)
try:
    with con.cursor() as cursor:
        result = cursor.execute(
        'update tb_dept set dname=%s, dloc=%s where dno=%s',
        (name, loc, no)
        )
        if result == 1:
            print('更新成功!')
finally:
    con.close()


if __name__ == '__main__':
    main()



#查询数据
import pymysql
from pymysql.cursors import DictCursor

def main():
con = pymysql.connect(host='localhost', port=3306,
        database='hrs', charset='utf8',
        user='yourname', password='yourpass')
try:
    with con.cursor(cursor=DictCursor) as cursor:
        cursor.execute('select dno as no, dname as name, dloc as loc from tb_dept')
        results = cursor.fetchall()
        print(results)
        print('编号\t名称\t\t所在地')
        for dept in results:
            print(dept['no'], end='\t')
            print(dept['name'], end='\t')
            print(dept['loc'])
finally:
    con.close()


if __name__ == '__main__':
    main()

  

标签:__,name,改查,Pymysql,cursor,pymysql,增删,main,con
From: https://www.cnblogs.com/xfbk/p/16705747.html

相关文章

  • Sqlite增删改查
    sqlite增删改查importsqlite3#如果文件不存在会自动创建conn=sqlite3.connect('test.db')#创建一个cursorcursor=conn.cursor()cursor.execute('DROPTABLEuser'......
  • 17.1 xlrd模块 17.2接口自动化第一版17.3pymysql模块 17.4接口自动化第二版
    17.1xlrd模块#xlrd和openpyxl#1.什么是xlrd模块?#python操作excel主要用到xlrd和xlwt这两个库,即xlrd是读excel,xlwt是写excel的库。#关于xlrd/xlwt和openpyxl的差别#......
  • Mysql数据库增删改查
    数据库显示数据库showdatabases;显示数据表showtables;选择数据库usemysql;创建数据库createdatabasehaige;删除数据库dropdatabasehaige;刷新权限flushprivilege......
  • msyql 的增删改查之基础语句
    增删改查增删改查的语句命苦为:操作命令增insert删delete改update查select或者show库操作:操作代码创建数据库 CREATEDATABASESshukuk......
  • 暑假代码训练项目增删改查(一)
    packagecom.atguigu.p2.bean;/***@DescriptionCustomer为实体对象,用来封装客户信息*@author高槐玉*@date2022年8月29日晚20:45**/publicclassCust......
  • 增删改查
    增:insertinto`table`(`id`,`name`,`sex`,`grade`)value('1','张三','男','三年级')删:deletefrom`table`where`id`='1'改:update'table'set`name`='李四'w......
  • MyBatis常用注解及基本增删改查的注解实现
    MyBatis的常用注解注解可以减少Mapper文件的编写,常用注解如下;@Insert:实现新增@Update:实现更新@Delete:实现删除@Select:实现查询@Result:实现结果集封装@Results:可......
  • 利用Java集合实现学生信息的”增删查“
    之前学了Java中的集合,打算写一个小程序来消化一下!那么我们知道,集合相比数组的优点就是可以动态的增加元素,这对比数组来说,十分的便捷;并且集合为我们封装好一些方法,可以更......
  • 通过postman实现数据列表的增删改查
    constKoa=require('koa')constrouter=require('koa-router')()constviews=require('koa-views')constnunjucks=require('nunjucks')constsession=re......
  • Python——pymysql(连接mysql数据库)
    基本设置(包括预防SQL注入):SQL注入问题,在写入sql语言时,可能会有利用mysql语句来进行正常输入的规避。importpymysqlconn=pymysql.connect(host='127.0.0.1',user......