zoukankan      html  css  js  c++  java
  • python3.6使用mysql

    因为MySQLdb不支持python3,需要导入pymysql

    可以选择pip 安装pymysql,或者pycharm安装 

    [File] >> [settings] >> [Project: python] >> [Project Interpreter] >> "+"

    import pymysql.cursors
    
    # 连接数据库
    connect = pymysql.Connect(
        host='localhost',
        port=3310,
        user='root',
        passwd='root',
        db='python',
        charset='utf8'
    )
    
    # 获取游标
    cursor = connect.cursor()
    
    # 插入数据
    sql = "INSERT INTO trade (name, account, saving) VALUES ( '%s', '%s', %.2f )"
    data = ('雷军', '13512345678', 10000)
    cursor.execute(sql % data)
    connect.commit()
    print('成功插入', cursor.rowcount, '条数据')
    
    # 修改数据
    sql = "UPDATE trade SET saving = %.2f WHERE account = '%s' "
    data = (8888, '13512345678')
    cursor.execute(sql % data)
    connect.commit()
    print('成功修改', cursor.rowcount, '条数据')
    
    # 查询数据
    sql = "SELECT name,saving FROM trade WHERE account = '%s' "
    data = ('13512345678',)
    cursor.execute(sql % data)
    for row in cursor.fetchall():
        print("Name:%s	Saving:%.2f" % row)
    print('共查找出', cursor.rowcount, '条数据')
    
    # 删除数据
    sql = "DELETE FROM trade WHERE account = '%s' LIMIT %d"
    data = ('13512345678', 1)
    cursor.execute(sql % data)
    connect.commit()
    print('成功删除', cursor.rowcount, '条数据')
    
    # 事务处理
    sql_1 = "UPDATE trade SET saving = saving + 1000 WHERE account = '18012345678' "
    sql_2 = "UPDATE trade SET expend = expend + 1000 WHERE account = '18012345678' "
    sql_3 = "UPDATE trade SET income = income + 2000 WHERE account = '18012345678' "
    
    try:
        cursor.execute(sql_1)  # 储蓄增加1000
        cursor.execute(sql_2)  # 支出增加1000
        cursor.execute(sql_3)  # 收入增加2000
    except Exception as e:
        connect.rollback()  # 事务回滚
        print('事务处理失败', e)
    else:
        connect.commit()  # 事务提交
        print('事务处理成功', cursor.rowcount)
    
    # 关闭连接
    cursor.close()
    connect.close()
    def insert_data(news_list):
        try:
            connect = get_connect()
            cursor = connect.cursor()
    
            for news in news_list:
                sql = "INSERT INTO news(title, tag, source, source_url, keyword, keywords) VALUES ( %s,%s,%s,%s,%s,%s)"
                #data = {news.title, news.tag, news.source, news.source_url, news.keyword, news.keywords}
                cursor.execute(sql, (news.title, news.tag, news.source, news.source_url, news.keyword, news.keywords))
            connect.commit()
        except Exception as e:
            print(e)
        finally:
            cursor.close()
            connect.close()
    def select_url():
        arrList = []
        try:
            connect = get_connect()
            cursor = connect.cursor()
            print("connection")
            sql = "SELECT id,source_url FROM news"
            cursor.execute(sql)
            result = cursor.fetchall()
            for row in result:
                # print(row[0])
                news = News()
                news.source_url = row[1]
                arrList.append(news)
        except Exception as e:
            print(e)
        finally:
            return arrList
  • 相关阅读:
    phome_enewsclass 数据表字段解释(栏目主表)
    phome_ecms_news 数据表字段解释(新闻系统模型-主表)
    帝国cms7.2灵动标签万能教程
    帝国cms7.2自定义列表建立tag效果 代码 教程
    栏目自定义变量怎么用?
    给你的网站404页面加上“宝贝寻亲”公益页面
    discuz_style_default.xml修改
    谈谈几大宗教.
    discuz默认模板文件结构详解-模板文件夹介绍
    一些适合用手柄玩的网络游戏
  • 原文地址:https://www.cnblogs.com/bincoding/p/6789456.html
Copyright © 2011-2022 走看看