public class TriggerService {
    private final String dataSource;

    public TriggerService(String dataSource) {
        this.dataSource = dataSource;
    }

    public void init() {
        JdbcTemplate.executeInit(
                dataSource,
                "CREATE TABLE IF NOT EXISTS houses(id INTEGER PRIMARY KEY, price INTEGER NOT NULL, district TEXT NOT NULL, underground TEXT NOT NULL);"
        );
    }

    public House insert(House house) {
        JdbcTemplate.executeCreateQuery(
                dataSource,
                "INSERT INTO houses (price, district, underground) VALUES(?, ?, ?);",
                pstmt -> {
                    pstmt.setInt(1, house.getPrice());
                    pstmt.setString(2, house.getDistrict());
                    pstmt.setString(3, house.getUnderground());
                }
        );
        return house;
    }

    public House update(House house) {
        JdbcTemplate.executeCreateQuery(
                dataSource,
                "UPDATE houses SET price = ?, district = ?, underground = ? WHERE id = ?;",
                pstmt -> {
                    pstmt.setInt(1, house.getPrice());
                    pstmt.setString(2, house.getDistrict());
                    pstmt.setString(3, house.getUnderground());
                    pstmt.setInt(4, house.getId());
                }
        );
        return house;
    }

    public void initTrigger() {
        JdbcTemplate.executeInit(
                dataSource,
                "CREATE TABLE IF NOT EXISTS houses_trigger(new_id INTEGER PRIMARY KEY, new_price INTEGER NOT NULL, new_district TEXT NOT NULL, new_underground TEXT NOT NULL, date TEXT NOT NULL, operation TEXT NOT NULL);"
        );
        JdbcTemplate.executeInit(
                dataSource,
                "CREATE TRIGGER IF NOT EXISTS after_insert AFTER INSERT ON houses BEGIN INSERT INTO houses_trigger(new_id, new_price, new_district, new_underground, date, operation) VALUES (NEW.id, NEW.price, NEW.district, NEW.underground, datetime('now'), 'ins');END;"
        );
        JdbcTemplate.executeInit(
                dataSource,
                "CREATE TRIGGER IF NOT EXISTS after_update AFTER UPDATE ON houses BEGIN INSERT INTO houses_trigger(new_id, new_price, new_district, new_underground, date, operation) VALUES (OLD.id, OLD.price, OLD.district, OLD.underground, datetime('now'), 'upd');END;"
        );
    }

    public List<House> getAllChanges(String date) {
        return JdbcTemplate.executeQuery(
                dataSource,
                "SELECT new_id, new_price, new_district, new_underground, date FROM houses_trigger WHERE date LIKE '" + date + "%'",
                rs -> new House(
                        rs.getInt("new_id"),
                        rs.getInt("new_price"),
                        rs.getString("new_district"),
                        rs.getString("new_underground"),
                        rs.getString("date")

                )
        );
    }
}

public class JdbcTemplate {

    private static <T> T execute(String dataSource, String sql, PreparedStatementExecutor<T> executor) {
        try (
                Connection connection = DriverManager.getConnection(dataSource);
                PreparedStatement preparedStatement = connection.prepareStatement(sql)
        ) {
            return executor.execute(preparedStatement);
        } catch (SQLException e) {
            throw new DataAccesException();
        }
    }

    public static void executeInit(String dataSource, String sql) {

        try (
                Connection connection = DriverManager.getConnection(dataSource);
                Statement statement = connection.createStatement()

        ) {
            statement.execute(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static void executeCreateQuery(String dataSource, String sql, PreparedStatementSetter setter) {
        execute(dataSource, sql, pstmt -> {
            setter.set(pstmt);
            pstmt.execute();
            return null;
        });
    }

    public static <T> List<T> executeQuery(String dataSource, String sql, RowMapper<T> mapper) {
        return execute(dataSource, sql, pstmt -> {
            try (ResultSet resultSet = pstmt.executeQuery()) {
                List<T> result = new LinkedList<>();
                while (resultSet.next()) {
                    result.add(mapper.map(resultSet));
                }
                return result;
            }
        });
    }
}

System.out.println(triggerService.getAllChanges("2020-01-29"));

public void close() {
        try {
            preparedStatement.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }