使用spring jdbcTemplate将数据插入多个表

Still Learning 发表于 Dev

仍然在学习

我正在使用java，spring jdbc template将n条记录插入两个表中。像这样

假设daos.xml配置正确。

ApplicationContext ctxt = new ClassPathXmlApplicationContext("daos.xml");
JdbcTemplate template = (JdbcTemplate) ctxt.getBean("jdbcTemplate");

final List<Person> list = new ArrayList<>();
        final List<Role> roles = new ArrayList<>();
        for(int i =1; i<=100; i++){
            Person item = new Person();
            item.setFirstName("Naveen" + i);
            item.setLastName("kumar" + i);
            item.setDescription("D" + i);
            list.add(item);

            Role role = new Role();
            role.setName("Admin");
            role.setCode("c"  + i);
            roles.add(role);

        }

String sql = "insert into person(first_name, last_name, description) values(?,?,?)";

            int[] arr = template.batchUpdate(sql, new BatchPreparedStatementSetter() {

                        @Override
                        public void setValues(PreparedStatement ps, int i) throws SQLException                             {
                            Person person = list.get(i);
                            ps.setObject(1, person.getFirstName());
                            ps.setObject(2, person.getLastName());
                            ps.setObject(3, person.getDescription());
                        }

                        @Override
                        public int getBatchSize() {
                            return list.size()
                        }
                    });

我还配置了事务管理器。

所以我的问题是如何使用批处理将数据同时插入人和角色表。因为人可以扮演角色。当我插入人时，需要将角色ID一起插入。在这种情况下，人员插入查询将如下所示。

String sql = "insert into person(first_name, last_name, description, role_id) values(?,?,?, ?)";

我要成批执行。因为在我的情况下，我有至少1万个人要使用文件进行解析。因此，这可能是性能杀手，因为我将角色插入表中而不是将角色插入表中，然后他们再次插入人。

钉枪

您可以使用多通道语句和LAST_INSERT_ID()MySql函数：

String sql = "insert into role(name, code) values(?,?);" +
    "insert into person(first_name, last_name, description, role_id) values(?,?,?,(SELECT LAST_INSERT_ID()));";

int[] arr = template.batchUpdate(sql, new BatchPreparedStatementSetter() {

    @Override
    public void setValues(PreparedStatement ps, int i) throws SQLException {
        Role role = roles.get(i);
        Person person = list.get(i);
        ps.setObject(1, role.getName());
        ps.setObject(2, role.getCode();
        ps.setObject(3, person.getFirstName());
        ps.setObject(4, person.getLastName());
        ps.setObject(5, person.getDescription());
    }

    @Override
    public int getBatchSize() {
        return list.size()
    }
});