使用 java 和 mybatis spring 在 EKS 中运行的应用程序中插入和更新值到 oracle 的问题

问题描述

我有一个 java spring 独立应用程序，它将向 Oracle 插入/更新对象列表。当我在本地运行时，它会遍历循环并插入和更新所有对象。但是，当我在 EKS 中部署相同的应用程序（它是一个批处理作业）时，它正在插入/更新第一个对象并关闭连接，紧接着 spring 上下文也关闭了。所以它不会插入/更新除第一个对象之外的所有对象。注意：在日志中没有看到任何异常

我正在使用 mybatis-spring 与 oracle 交互。我的查询是这样的

<insert id="insert" parameterType="com.mycompany.Employee">
        INSERT INTO TABLE (col1,col2,....)
        VALUES (val1,val2,val3,....)
    </insert>

<update id="update" parameterType="ccom.x.x.x">
    UPDATE TABLE
    SET
    col1 = #{subadv_acctng_clos_prc},col2 = #{local_subadv_acctng_clos_prc},.
    .
    
    WHERE colx = valx
</update> 

我的 Dao impl 看起来像这样

public void insert(Employee emp) {
        try {
            getsqlSession().insert("Map.insert",emp);
        } catch (Exception e) {
            log.error("Error while inserting:" + e.getMessage());
        }
    }
public int update(Employee emp) {
        int status = 0;
        try {
            status = getsqlSession().update("Map.update",emp);
        } catch (Exception e) {
            log.error("Error while updating:" + e.getMessage());
        }
        return status;
    }

调用方法

void Insert(List<EMp> list)
{
     for (Iterator iterator = list.iterator(); iterator.hasNext(); )
     {
      Emp emp= iterator.next();
        int status=update(emp);
      if(status==0)
        {
         insert(emp)
        }
      }
 }

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）