Python 数据库查询及数据导入

#查询数据库数据

#Python  连接sql sever  并进行数据查询

import pymmsql

connect=pymssql.connect(host='服务器名称', user='用户名',password='密码',database='数据库名称')#创建链接对象

cur=connect.cursor()#创建连接游标

cur.execute('select  *  from boss')#执行查询操作

print (cur.fetchall())#读取游标内容，并打印

cur.close()#查询之后关闭游标

connect.close()#关闭连接

#批量导入

table = data01['ORGANIZE_NAME']#数据框的 ORGANIZE_NAME列

#批量导入

def insert_by_many(table):

      nrows =len(table)

      param=[]

      for iin range(nrows):

    # 第一列username，第二列salt

    #，第三列pwd

                param.append(str(table[i]))#这个地方要注意 ，一个列表是一列数据，是批量导入的关键

        try:

                  sql ="INSERT INTO aaaaa(ORGANIZE_NAME) values(%s)"

                # 批量插入

                cur.executemany(sql,param)

        except Exception as e:

                    print (e)

        print ('[insert_by_many executemany] total:', nrows -1)# 查看已经插入多少行

insert_by_many(table)