如何使用spring JdbcTemplate更新postgresql数组列?

问题描述 投票:2回答:7

我正在使用Spring JdbcTemplate,我遇到的问题是我有一个更新实际上是int数组的列的查询。数据库是postgres 8.3.7。这是我正在使用的代码:

public int setUsersArray(int idUser, int idDevice, Collection<Integer> ids) {

    int update = -666;

    int[] tipi = new int[3];
    tipi[0] = java.sql.Types.INTEGER;
    tipi[1] = java.sql.Types.INTEGER;
    tipi[2] = java.sql.Types.ARRAY;

    try {
        update = this.jdbcTemplate.update(setUsersArrayQuery, new Object[] {
                ids, idUser, idDevice }, tipi);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return update;
}

查询是“update table_name set array_column =?where id_user =?and id_device =?”。我得到这个例外:

org.springframework.dao.DataIntegrityViolationException:PreparedStatementCallback; SQL [更新acotel_msp.users_mau设置denied_sub_client =? id_users =?和id_mau =?];列索引超出范围:4,列数:3。嵌套异常是org.postgresql.util.PSQLException:列索引超出范围:4,列数:3。

引起:org.postgresql.util.PSQLException:列索引超出范围:4,列数:3。

我已经查看了spring jdbc模板文档,但我找不到任何帮助,我会继续寻找,无论如何有人能指出我正确的方向吗?谢谢!

编辑:

显然订单错了,我的错......

我尝试了两种解决方案,在第一种情况下,我有这个:

org.springframework.jdbc.BadSqlGrammarException:PreparedStatementCallback;错误的SQL语法[更新用户设置denied_sub_client =? id_users =?和id_device =?];嵌套异常是org.postgresql.util.PSQLException:无法将java.util.ArrayList的实例强制转换为Types.ARRAY类型

尝试第二个解决方案,我有这个:

org.springframework.jdbc.BadSqlGrammarException:PreparedStatementCallback;错误的SQL语法[更新用户设置denied_sub_client =? id_users =?和id_device =?];嵌套异常是org.postgresql.util.PSQLException:无法强制转换[Ljava.lang.Object;键入Types.ARRAY

我想我需要一个java.sql.Array实例,但是如何使用JdbcTemplate创建它?

arrays spring postgresql jdbctemplate
7个回答
2
投票
private static final String ARRAY_DATATYPE = "int4";
private static final String SQL_UPDATE = "UPDATE foo SET arr = ? WHERE d = ?";
final Integer[] existing = ...;
final DateTime dt = ...;

getJdbcTemplate().update(new PreparedStatementCreator() {
    @Override
    public PreparedStatement createPreparedStatement(final Connection con) throws SQLException {
        final PreparedStatement ret = con.prepareStatement(SQL_UPDATE);
        ret.setArray(1, con.createArrayOf(ARRAY_DATATYPE, existing));
        ret.setDate(2, new java.sql.Date(dt.getMillis()));
        return ret;
    }
});

1
投票

参数类型和参数不匹配。

尝试更改参数类型顺序

int[] tipi = new int[3];
tipi[0] = java.sql.Types.ARRAY;
tipi[1] = java.sql.Types.INTEGER;
tipi[2] = java.sql.Types.INTEGER;

或使用

update = this.jdbcTemplate.update(setUsersArrayQuery, new Object[] {
                                ids.toArray(), idUser, idDevice })

看看它是否有效


1
投票

http://valgogtech.blogspot.com/2009/02/passing-arrays-to-postgresql-database.html解释了如何创建java.sql.Array postgresql基本上Array.getBaseTypeName应该返回int而Array.toString应该以“{1,2,3}”格式返回数组内容

创建数组后,您可以使用PreparedStatementCreator中的preparedstatement.setArray(...)来设置它。

jdbcTemplate.update(
    new PreparedStatementCreator() {
        public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {

祝好运 ..


1
投票

这个解决方案是一种使用postgreSQL内置函数的解决方法,这对我来说绝对有效。

reference blog

1)将字符串数组转换为逗号分隔字符串

如果您使用的是Java8,那就非常简单了。其他选择是here

String commaSeparatedString = String.join(",",stringArray); // Java8 feature

2)PostgreSQL内置函数string_to_array()

你可以找到其他postgreSQL数组函数here

// tableName ( name text, string_array_column_name text[] )

String query = "insert into tableName(name,string_array_column_name ) values(?, string_to_array(?,',') )";


int[] types = new int[] { Types.VARCHAR, Types.VARCHAR};

Object[] psParams = new Object[] {"Dhruvil Thaker",commaSeparatedString };

jdbcTemplate.batchUpdate(query, psParams ,types); // assuming you have jdbctemplate instance

0
投票

到目前为止我发现的最干净的方法是首先将Collection转换为Integer[],然后使用Connection将其转换为Array

Integer[] idArray = ids.toArray(new Integer[0]);

Array idSqlArray = jdbcTemplate.execute(
        (Connection c) -> c.createArrayOf(JDBCType.INTEGER.getName(), idArray)
);

update = this.jdbcTemplate.update(setUsersArrayQuery, new Object[] {
                            idSqlArray, idUser, idDevice })

这是基于文档中的信息:https://jdbc.postgresql.org/documentation/head/arrays.html


0
投票

经过多次尝试后,我们决定使用一个小助手ArraySqlValue为Java数组类型创建Spring SqlValue对象。

用法是这样的

jdbcTemplate.update(
                "UPDATE sometable SET arraycolumn = ?",
                ArraySqlValue.create(arrayValue))

ArraySqlValue也可以在MapSqlParameterSource中使用,以与NamedParameterJdbcTemplate一起使用。

import static com.google.common.base.Preconditions.checkNotNull;

import java.sql.Array;
import java.sql.JDBCType;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Locale;

import org.springframework.jdbc.core.StatementCreatorUtils;
import org.springframework.jdbc.support.SqlValue;

public class ArraySqlValue implements SqlValue {
    private final Object[] arr;
    private final String   dbTypeName;

    public static ArraySqlValue create(final Object[] arr) {
        return new ArraySqlValue(arr, determineDbTypeName(arr));
    }

    public static ArraySqlValue create(final Object[] arr, final String dbTypeName) {
        return new ArraySqlValue(arr, dbTypeName);
    }

    private ArraySqlValue(final Object[] arr, final String dbTypeName) {
        this.arr = checkNotNull(arr);
        this.dbTypeName = checkNotNull(dbTypeName);
    }

    @Override
    public void setValue(final PreparedStatement ps, final int paramIndex) throws SQLException {
        final Array arrayValue = ps.getConnection().createArrayOf(dbTypeName, arr);
        ps.setArray(paramIndex, arrayValue);
    }

    @Override
    public void cleanup() {}

    private static String determineDbTypeName(final Object[] arr) {
        // use Spring Utils similar to normal JdbcTemplate inner workings
        final int sqlParameterType =
            StatementCreatorUtils.javaTypeToSqlParameterType(arr.getClass().getComponentType());
        final JDBCType jdbcTypeToUse = JDBCType.valueOf(sqlParameterType);
        // lowercasing typename for Postgres
        final String typeNameToUse = jdbcTypeToUse.getName().toLowerCase(Locale.US);
        return typeNameToUse;
    }
}

此代码在Public Domain中提供


-1
投票
java.sql.Array intArray = connection.createArrayOf("int", existing);
List<Object> values= new ArrayList<Object>();
values.add(intArray);
values.add(dt);
getJdbcTemplate().update(SQL_UPDATE,values);
© www.soinside.com 2019 - 2024. All rights reserved.