Простой jdbcTemplate.query () должен возвращать список, но не - PullRequest
Новая
       17

Простой jdbcTemplate.query () должен возвращать список, но не

0 голосов
/ 07 ноября 2018

Я использую Spring 4.0 (загрузочный), а вот код: 

        String sql = "SELECT emp_id,name,role FROM employees";
        List<Employee> employees = jdbcTemplate.query(sql,(rs, rowNum)-> 
        new Employee(rs.getInt("emp_id"), rs.getString("name"),
                rs.getString("role")));         
        employees.forEach(employee -> {log.info(employee.toString());
            log.info("part a");});

Код выглядит таким простым и понятным, но проблема в том, что сотрудники вообще ничего не возвращают в журналах. Разве это не означает, что все в сотрудниках является нулевым?

Не должно быть никаких проблем с самим регистратором, потому что регистрация перед этим кодом работает.

База данных правильно введена. Когда я делаю запрос через клиент MySQL, я вижу их там.

Какую ошибку Java я делаю (если она есть)?

EDIT: это полная функция, в которой я выполняю простые запросы к базе данных, и из которых исходит приведенный выше код: 

    @Override
    public void run(String... args) throws Exception {
        log.info("Creating tables");

        jdbcTemplate.execute("DROP TABLE IF EXISTS employee");
        jdbcTemplate.execute("CREATE TABLE employee (emp_id int, name varchar(100), role varchar(100))");

        log.info("Inserting Baggins Hopkins");
        int rowsAffected = jdbcTemplate.update("INSERT INTO EMPLOYEE(EMP_ID, NAME, ROLE)"
                + " VALUES(1,'Baggins Hopkins','thief')");
        log.info("rows affected: "+ Integer.toString(rowsAffected));
        int rowsAffected1 = jdbcTemplate.update("INSERT INTO EMPLOYEE(EMP_ID, NAME, ROLE)"
                + " VALUES(2,'Doolous Hopkins','robber')");
        log.info("rows affected: "+ Integer.toString(rowsAffected1));
        log.info("Querying for employee");
        String sql = "SELECT emp_id,name,role FROM employee";
        List<Employee> employees = jdbcTemplate.query(sql,(rs, rowNum)-> 
        new Employee(rs.getInt("emp_id"), rs.getString("name"),
                rs.getString("role")));
        log.info("Part A:");
        log.info(String.valueOf(employees.isEmpty()));
//      List<Employee> employees = new ArrayList<Employee>();
//      final List<Map<String, Object>> rows = jdbcTemplate.queryForList(sql);
//      for(final Map row : rows) {
//          Employee employee = new Employee();
//          employee.setId((int)row.get("emp_id"));
//          employee.setName((String)row.get("name"));
//          employee.setRole((String)row.get("role"));
//      };

        employees.forEach(employee -> {log.info(employee.toString());
            log.info("part a");});

    }

Это журнал, который пришел, когда произошла ошибка: 

 :: Spring Boot ::        (v2.1.0.RELEASE)

2018-11-07 22:08:36.599  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : Starting JdbcTest1Application on KitKat with PID 5476 (C:\Users\Nano\Downloads\jdbc-test1\jdbc-test1\target\classes started by Nano in C:\Users\Nano\Downloads\jdbc-test1\jdbc-test1)
2018-11-07 22:08:36.599  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : No active profile set, falling back to default profiles: default
2018-11-07 22:08:37.458  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : Started JdbcTest1Application in 1.156 seconds (JVM running for 2.08)
2018-11-07 22:08:37.474  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : Creating tables
2018-11-07 22:08:37.474  INFO 5476 --- [           main] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Starting...
2018-11-07 22:08:37.614  INFO 5476 --- [           main] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Start completed.
2018-11-07 22:08:38.873  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : Inserting Baggins Hopkins
2018-11-07 22:08:39.042  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : rows affected: 1
2018-11-07 22:08:39.183  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : rows affected: 1
2018-11-07 22:08:39.183  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : Querying for employee
2018-11-07 22:08:39.214  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : Part A:
2018-11-07 22:08:39.214  INFO 5476 --- [           main] c.j.jdbctest1.JdbcTest1Application       : true
2018-11-07 22:08:39.230  INFO 5476 --- [       Thread-1] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown initiated...
2018-11-07 22:08:39.230  INFO 5476 --- [       Thread-1] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown completed.

Ответы [ 2 ]

0 голосов
/ 07 ноября 2018

Ответ от автора оригинала:

Это была простая синтаксическая ошибка. Как отметили комментаторы, я вставил не в ту таблицу ... мой синтаксис в моих sql запросах был неправильным.

Раньше я вставлял в «служащие», но я должен был вставлять в «служащий».

queryForList (), который возвращает List, содержащий Map, однако, все еще возвращает ноль. Я прокомментировал это в посте выше. Я не знаю, что с этим не так (раньше я не пробовал использовать List>). Но проблема решена.

0 голосов
/ 07 ноября 2018

Вы можете использовать другой способ получения списка сотрудников: 

private static final RowMapper<Employee> ROW_MAPPER = BeanPropertyRowMapper.newInstance(Employee.class);

String sql = "SELECT emp_id,name,role FROM employees";
List<Employee> employees = jdbcTemplate.query(sql, ROW_MAPPER);

или 

List<Employee> employees = jdbcTemplate.queryForList(sql, Employee.class);
...