zoukankan      html  css  js  c++  java
  • pymysql

    基础知识

    pip install pymyql

    import pymysql
    #tcp客户端程序
    #建立连接,传输数据

    conn=pymysql.connect(host='127.0.0.1',user='root',database='demo') #创建连接用correct方法

    cur=conn.cursor()  #获取游标,创建连接之后,获取游标

    cur.execute('''insert into `user`(`name`,`age`)value('harden',18)''')  #执行sql

    conn.commit() #提交事务

    非查询性请求的四个步骤 1.创立连接 2.获取游标 3.执行sql 4.提交事务

    cur.execute("""insert into `user`(`name`,`age`)values('pets',34)""")#游标关闭之前可以反复使用

    1.

    with cur: #自动关闭游标
    cur.execute('''insert into `user`(`name`,`age`)value('kobe',39)''')

    2.

    with conn as cur: #自动提交事务,部关闭cur
    cur.execute('''insert into `user`(`name`,`age`)value('kobe',39)''')

    3.

    with conn as cur: #自动提交事务,
    with cur: #自动关闭游标
    cur.execute('''insert into `user`(`name`,`age`)value('tim',25)''')

    4.

    from queue import Queue
    class ConnectionPool:
    def __init__(self,size,*args,**kwargs):
    self._pool=Queue(size)
    self.args=args
    self.kwargs=kwargs
    for x in range(size):
    self._pool.put(self._connect())

    def _connect(self):
    return pymysql.connect(*self.args,**self.kwargs)

    def close(self,conn):
    conn.close()

    def get(self):
    return self._pool.get()

    def return_resource(self,conn):
    self._pool.put()

    本文为原创文章,转载请标明出处
  • 相关阅读:
    redis/memcached可视化客户端工具TreeNMS
    Navicat Mysql快捷键
    mysql全文索引之模糊查询
    Discuz网警过滤关键词库
    php中的implements 使用详解
    PHP 依赖注入和控制反转再谈(二)
    php 中的closure用法
    C# 反射(Reflection)技术
    Oracle pl/sql编程值控制结构
    Oracle PL/SQL编程之变量
  • 原文地址:https://www.cnblogs.com/harden13/p/6893983.html
Copyright © 2011-2022 走看看