zoukankan      html  css  js  c++  java
  • Python 连接MySQL 增删改查 直接可用(最简易,含源码)

    直接上源码:

     1 import pymysql
     2 
     3 db = pymysql.connect(host='localhost',
     4                      port=3306,
     5                      user='root',
     6                      passwd='zb753951',
     7                      db='pareci')
     8 def select_db():
     9     '''查询数据库'''
    10     # 打开数据库连接
    11 
    12     sql = "select * from blog_info"
    13     # 使用 cursor() 方法创建一个游标对象cur
    14     cur = db.cursor()
    15 
    16     # 使用 execute()  方法执行 SQL 查询
    17     cur.execute(sql)
    18 
    19     # 使用 fetchall() 方法获取查询结果
    20     data = cur.fetchall()
    21     # print(data)  # 取出对应的psw值
    22     # 关闭数据库连接
    23     #db.close()
    24     return data
    25 
    26 def delete_db():
    27     '''删除操作'''
    28     # 使用cursor()方法获取操作游标
    29     cur = db.cursor()
    30     sql_delete = "delete from word_info_num "
    31     try:
    32         cur.execute(sql_delete)  # 执行
    33         # 提交
    34         db.commit()
    35     except Exception as e:
    36         print("操作异常:%s" % str(e))
    37         # 错误回滚
    38         db.rollback()
    39     #finally:
    40         #db.close()
    41 
    42 def update_db():
    43     '''3.更新操作'''
    44     # 使用cursor()方法获取操作游标
    45     cur = db.cursor()
    46     sql_update = "update user set psw='666666' where name='yoyo'"
    47     try:
    48         cur.execute(sql_update)  # 执行sql
    49         # 提交
    50         db.commit()
    51     except Exception as e:
    52         # 错误回滚
    53         print("错误信息:%s" % str(e))
    54         db.rollback()
    55     #finally:
    56         #db.close()
    57 
    58 def insert_db(Name,Num,Title,Url):
    59     '''插入操作'''
    60     # 使用cursor()方法获取操作游标
    61     cur = db.cursor()
    62 
    63     sql_insert= "insert into word_info_num (Name, Num, Title,Url) values('"+Name+"','"+Num+"','"+Title+"','"+Url+"')"
    64     print(sql_insert)
    65     try:
    66         cur.execute(sql_insert)
    67         # 提交
    68         db.commit()
    69     except Exception as e:
    70         print("错误信息:%s" % str(e))
    71         # 错误回滚
    72         db.rollback()
    73     #finally:
    74         #db.close()
    75 if __name__ == "__main__":
    76 
    77     values=select_db()
    78     i=0
    79     for value in values:
    80         i=i+1
    81         print(value[2])
    82 
    83     a = select_db()[0][0]
    84     print("查询结果:%s" %str(a))
    85 
    86     #删除
    87 
    88     #delete_db()
    89 
    90     #修改
    91 
    92     #update_db()
    93 
    94     #insert_db()
  • 相关阅读:
    用initconnect+binlog实现用户操作追踪【转】
    INSERT INTO … SELECT 的锁【转】
    Memcached 高可用方案 Repcached
    关于MySQL建表对DML的影响【转】
    NoSQL之【memcached】学习
    关于MySQL insert into ... select 的锁情况
    MySQL数据库诊断——InnoDB关机问题 【转】
    Your document is being created
    Failure to Get Sequential Numbering Profile Option
    Runtime error '1004'
  • 原文地址:https://www.cnblogs.com/smartisn/p/12255978.html
Copyright © 2011-2022 走看看