Pandas DF SQL DELETE FROM

问题描述 投票:0回答:1

我正在尝试设置一个脚本,该脚本将允许SQL查询和转换为pandas df。我在尝试使用DELETE FROM语句时遇到了一个问题。我目前有这样的东西:

import os
import boto3
import pandas as pd
import pandasql as ps

csv_file_path = 's3://bucket/folder/test.csv'
df = pd.read_csv(csv_file_path)

sql_mod = '''DELETE FROM df WHERE opt_out = 1'''
df1 = ps.sqldf(sql_mod, locals())
print(df1)

而且我正在从s3中读取的表看起来像这样

  customer    cust_id      phone_nm          addr          date        order  opt_out
0     John   13251236  123-456-7890  2.893746e+10  8.760298e+07    298746746        0
1     Alex  234623476  234-567-8901  2.834760e+08  9.824770e+09      8746972        0
2   Amanda     151351  345-678-9012  2.090000e+14  9.750000e+11   9712975917        1
3    Carol    4236246  456-789-0123  9.284750e+07  7.346908e+10   9857897947        0
4     Carl   73457357  567-890-1234  2.934757e+09  3.746972e+08     97234967        1
5    Karen   15313513      678-9012  2.948769e+10  2.348760e+06      2436ou2        1
8    Scott    2573567  901-234-5678  9.723497e+07  9.723461e+07   9f29h34tin        0

但是我的delete语句似乎返回NULL DF。有没有一种方法可以使用保留标准SQL格式的pandas df运行SQL DELETE和INSERT?

我正在尝试设置一个脚本,该脚本将允许SQL查询和转换为pandas df。我在尝试使用DELETE FROM语句时遇到了一个问题。我目前有东西...

python pandas dataframe sql-delete
1个回答
0
投票

您需要select语句而不是delete语句。

© www.soinside.com 2019 - 2024. All rights reserved.