0

jaydebeapi executemany() 方法不适用于仅包含一个参数的 sql 查询，但同时两个参数可以正常工作。

例如给定的查询不执行：

cursor.executemany("DELETE FROM table1 WHERE col1 = ?", tup_df)

这个工作正常

cursor.executemany("DELETE FROM table1 WHERE col1 = ? AND col2 = ?", tup_df)

假设后面的表达式AND使用数据库中的现有列进行操作（使用一些类似的变通方法1 = ?没有成功）

使用第一种情况测试代码

df = pandas.DataFrame(data={'col1': [3563412]})

conn = jaydebeapi.connect(jar_class, url, {'user': user, 'password': password}, jar_path)

cursor = conn.cursor()

row_count = 0

for _, df in df.groupby(np.arange(len(df)) // 2000):
    tup_df = [tuple(x) for x in df.values]
    cursor.executemany("DELETE FROM table1 WHERE col1 = ?", tup_df)
    row_count = row_count + cursor.rowcount

print(row_count + ' row(s) processed')

第二种情况的测试代码

df = pandas.DataFrame(data={'col1': [3563412]})

conn = jaydebeapi.connect(jar_class, url, {'user': user, 'password': password}, jar_path)

cursor = conn.cursor()

row_count = 0

for _, df in df.groupby(np.arange(len(df)) // 2000):
    tup_df = [tuple(x) for x in df.values]
    cursor.executemany("DELETE FROM table1 WHERE col1 = ? AND col2 = ?", tup_df)
    row_count = row_count + cursor.rowcount

print(row_count + ' row(s) processed')

投掷错误：

Traceback (most recent call last):
  File "test.py", line 21, in <module>
    cursor.executemany("DELETE FROM table1 WHERE col1 = ?", tup_df)
  File "/home/ray/.local/lib/python3.6/site-packages/jaydebeapi/__init__.py", line 516, in executemany
    self._set_stmt_parms(self._prep, parameters)
  File "/home/ray/.local/lib/python3.6/site-packages/jaydebeapi/__init__.py", line 490, in _set_stmt_parms
    prep_stmt.setObject(i + 1, parameters[i])
RuntimeError: No matching overloads found for setObject in find. at native/common/jp_method.cpp:127

当前数据库是 db2，jaydebeapi - 1.1.1，jpype - 0.6.3，python - 3.6。更改数据库没有帮助。任何帮助将不胜感激。

4

1 回答 1

0

我认为问题是由于尝试将 NumPy 值插入数据库而引起的，而 jaydebeapi 和 JPype 都没有处理这些值。

如果您查看 jaydebeapi 模块的源代码，/home/ray/.local/lib/python3.6/site-packages/jaydebeapi/__init__.py根据您问题中的回溯，您可能会看到注释掉的行

        # print (i, parameters[i], type(parameters[i]))

内_set_stmt_params。这是我机器上的第 489 行。我取消了这一行的注释，运行了你的代码，我得到了以下输出：

0 3563412 <class 'numpy.int64'>

这告诉我参数值3563412是一个 NumPy 64 位整数值。

我最好的猜测是出现错误是因为 jaydebeapi 和 JPype 都不知道如何将其转换为 Java 值。

在我看来，好像您必须使用以下内容将数据帧的每一行的值转换为ints （或其他可以转换为 Java 的 Python 类型）：

tup_df = [tuple(int(y) for y in x) for x in df.values]

我对您的代码进行了此更改，它不再在您的问题中产生错误。

如果 NumPy 或 Pandas 中有内置函数可以为您执行此操作，请随意使用它。

顺便说一句，我在使用一个或两个参数时遇到了同样的错误：在双参数情况下，事情对我来说并没有正常工作，就像他们对你所做的那样。

于 2019-12-05T22:36:09.953 回答