百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 优雅编程 > 正文

使用python如何将查询结果,转换为insert脚本?

sinye56 2024-10-18 12:56 8 浏览 0 评论

import cx_Oracle as ora
import time
import re
from queue import Queue
import os
'''
适用一段sql内,只有一个from的,有嵌套的,需要调整;
需要写入:file_path,获取sql文件路径,注意最后的sql不能有分号;
输出文件:08_out,需要提前清空文件夹内的文件;
写slq最好加上scharma名称;
'''
# 清空路径下的文件
out_path="./08_out"
l=os.listdir(out_path)
for i in l:
    rm_path=out_path+'/'+i
    os.remove(rm_path)
# 获取sql
file_path=r"C:\Users\admin\Desktop\t\t1.sql"
with open(file_path,'r',encoding='utf-8') as f:
    t=f.read()
    l=t.split(';')
# values字符串拼接:传入一个元组,返回字符串,对记录进行处理
# t=('f','e',None)
def get_value(t):
    L=[]
    for i in t:
        if i==None:
            L.append('NULL')
        else:
            L.append(i)
    tup=str(tuple(L))
    s = '''VALUES%s''' %tup
    new_s = s.replace("'NULL'", 'NULL')
    return new_s
# 传入列表,返回一个字符串,用于处理字段名称
def get_ziduan(l):
    tup = str(tuple(l))
    s = '''%s''' % tup
    return s.replace("'","")
# 取出表名称
def get_table(s):
    uppe_s=s.upper()
    if 'WHERE' in uppe_s:
        resp=''.join(re.findall('(?<=FROM).*(?=WHERE)',uppe_s,re.S))
    else:
        resp=''.join(re.findall('(?<=FROM).*',uppe_s,re.S))
    resp1=resp.strip()
    if '.' in resp1:
        resp2=resp1.replace(''.join(re.findall('.*\.', resp1, re.S)), '')
    else:
        resp2=resp1
    return resp2

path=r"D:\33.oracle\instantclient-basic-windows.x64-21.11.0.0.0dbru\instantclient_21_11" # oracle数据库客户端存放路径
ora.init_oracle_client(path)

conn = ora.connect('用户名/密码@ip地址/数据库名字')#这里的顺序是用户名/密码@oracleserver的ip地址/数据库名字
cursor = conn.cursor()
print('连接数据库成功!')
# 循环取出每一段sql语句
for i in l:
    sql = i
    all = cursor.execute(sql)
    all_data=all.fetchall()
    # 获取字段名称列表
    columns = [row[0] for row in cursor.description]
    q=Queue()
    # 循环取出每行记录
    for n in all_data:
        out_sql='INSERT INTO '+get_table(i)+get_ziduan(columns) +'\n'+ get_value(n)+';'+'\n\n'
        q.put(out_sql)
        # 把所有的查询结果放在一个文件内
        with open('./08_out/resp.sql', 'a', encoding='utf-8') as f:
            f.write(out_sql)
    print('完成表:%s'%get_table(i))
    #根据不同的表名,写出不同的文件内
    while not q.empty():
        with open('./08_out/%s.sql'%get_table(i), 'a', encoding='utf-8') as f:
            f.write(q.get())
    time.sleep(2)






相关推荐

Linux在线安装JDK1.8

首先在服务器pingwww.baidu.com查看是否可以连网然后就可以在线下载一、下载安装JDK1.81、在下载安装的同时做好一些准备工作...

Linux安装JDK,超详细

1、了解RPMRPM是Red-HatPackageManager(RPM软件包管理器)的缩写,这一文件格式名称虽然打上了RedHat的标志,但是其原始设计理念是开放式的,现在包括OpenLinux...

Linux安装jdk1.8(超级详细)

前言最近刚购买了一台阿里云的服务器准备要搭建一个网站,正好将网站的一个完整搭建过程分享给大家!#一、下载jdk1.8首先我们需要去下载linux版本的jdk1.8安装包,我们有两种方式去下载安装...

Linux系统安装JDK教程

下载jdk-8u151-linux-x64.tar.gz下载地址:https://www.oracle.com/technetwork/java/javase/downloads/index.ht...

干货|JDK下载安装与环境变量配置图文教程「超详细」

1.JDK介绍1.1什么是JDK?SUN公司提供了一套Java开发环境,简称JDK(JavaDevelopmentKit),它是整个Java的核心,其中包括Java编译器、Java运行工具、Jav...

Linux下安装jdk1.8

一、安装环境操作系统:CentOSLinuxrelease7.6.1810(Core)JDK版本:1.8二、安装步骤1.下载安装包...

Linux上安装JDK

以CentOS为例。检查是否已安装过jdk。yumlist--installed|grepjdk或者...

Linux系统的一些常用目录以及介绍

根目录(/):“/”目录也称为根目录,位于Linux文件系统目录结构的顶层。在很多系统中,“/”目录是系统中的唯一分区。如果还有其他分区,必须挂载到“/”目录下某个位置。整个目录结构呈树形结构,因此也...

Linux系统目录结构

一、系统目录结构几乎所有的计算机操作系统都是使用目录结构组织文件。具体来说就是在一个目录中存放子目录和文件,而在子目录中又会进一步存放子目录和文件,以此类推形成一个树状的文件结构,由于其结构很像一棵树...

Linux文件查找

在Linux下通常find不很常用的,因为速度慢(find是直接查找硬盘),通常我们都是先使用whereis或者是locate来检查,如果真的找不到了,才以find来搜寻。为什么...

嵌入式linux基本操作之查找文件

对于很多初学者来说都习惯用windows操作系统,对于这个系统来说查找一个文件简直不在话下。而学习嵌入式开发行业之后,发现所用到的是嵌入式Linux操作系统,本想着跟windows类似,结果在操作的时...

linux系统查看软件安装目录的方法

linux系统下怎么查看软件安装的目录?方法1:whereis软件名以查询nginx为例子...

Linux下如何对目录中的文件进行统计

统计目录中的文件数量...

Linux常见文件目录管理命令

touch用于创建空白文件touch文件名称mkdir用于创建空白目录还可以通过参数-p创建递归的目录...

Linux常用查找文件方法总结

一、前言Linux系统提供了多种查找文件的命令,而且每种查找命令都具有其独特的优势,下面详细总结一下常用的几个Linux查找命令。二、which命令查找类型:二进制文件;...

取消回复欢迎 发表评论: