import MysqL.connector.poolingconfig = { "host": "localhost","port": 3306,"user": "root","password": "","database": "demo"}try: pool = MysqL.connector.pooling.MysqLConnectionPool( **config,pool_size=10 ) con = pool.get_connection() con.start_transaction() cursor = con.cursor() # 复制表结构 # sql= "create table t_emp_new like t_emp " # cursor.execute(sql) sql = "select avg(sal) as avg from t_emp" cursor.execute(sql) # 取一条记录 temp = cursor.fetchone() # 平均底薪 avg = temp[0] sql = " select deptno from t_emp group by deptno having avg(sal)> %s" cursor.execute(sql,[avg]) # 取出所有记录 temp = cursor.fetchall() # print(temp) # sql = "insert into t_emp_new select * from t_emp where deptno in ( " # for index in range(len(temp)): # one = temp[index][0] # if index < len(temp) -1 : # sql+= str(one)+ "," # else: # sql += str(one) # sql += ")" # # print(sql) insert into t_emp_new select * from t_emp where deptno in ( 10,20) # cursor.execute(sql) # sql = "delete from t_emp where deptno in (" # for index in range(len(temp)): # one = temp[index][0] # if index < len(temp)-1: # sql += str(one)+ "," # else: # sql += str(one) # sql += " )" # # delete from t_emp where deptno in (10,20) # # print(sql) # cursor.execute(sql) # 查询部门 编号 sql = " select deptno from t_dept where dname = %s" cursor.execute(sql,[‘SALES‘]) deptno = cursor.fetchone() # print(deptno[0]) 30 sql = "update t_emp_new set deptno = %s" cursor.execute(sql,[deptno[0]]) con.commit()except Exception as e: print(e) if ‘con‘ in dir(): con.close()总结
以上是内存溢出为你收集整理的python 链接mysql 修改查询删除语句全部内容,希望文章能够帮你解决python 链接mysql 修改查询删除语句所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)