fix
This commit is contained in:
@@ -14,7 +14,7 @@ import java.util.stream.Collectors;
|
|||||||
|
|
||||||
public class IikoOlapClient {
|
public class IikoOlapClient {
|
||||||
|
|
||||||
private static final Logger log = LoggerFactory.getLogger(IikoOlapClient.class);
|
private static final Logger log = LoggerFactory.getLogger("[IikoOlapClient]");
|
||||||
private final WebClient webClient;
|
private final WebClient webClient;
|
||||||
private final String iikoHost;
|
private final String iikoHost;
|
||||||
private final String iikoLogin;
|
private final String iikoLogin;
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ import java.util.List;
|
|||||||
|
|
||||||
public class IikoOlapColumnsImporter {
|
public class IikoOlapColumnsImporter {
|
||||||
|
|
||||||
private static final Logger log = LoggerFactory.getLogger(IikoOlapColumnsImporter.class);
|
private static final Logger log = LoggerFactory.getLogger("[IikoOlapColumnsImporter]");
|
||||||
private final Pool dbPool;
|
private final Pool dbPool;
|
||||||
private final IikoOlapClient iikoOlapClient;
|
private final IikoOlapClient iikoOlapClient;
|
||||||
|
|
||||||
|
|||||||
@@ -54,12 +54,6 @@ public class RestaurantService {
|
|||||||
return pool.query(createTable).execute().mapEmpty();
|
return pool.query(createTable).execute().mapEmpty();
|
||||||
}
|
}
|
||||||
|
|
||||||
public Future<Long> countRestaurant() {
|
|
||||||
return pool.query("SELECT COUNT(*) AS cnt FROM restaurants")
|
|
||||||
.execute()
|
|
||||||
.map(rows -> rows.iterator().next().getLong("cnt"));
|
|
||||||
}
|
|
||||||
|
|
||||||
public Future<Void> createRestaurant(String name, String login, String password, String host, boolean https) {
|
public Future<Void> createRestaurant(String name, String login, String password, String host, boolean https) {
|
||||||
String hashedPassword = hashPassword(password);
|
String hashedPassword = hashPassword(password);
|
||||||
Map<String, Object> params = Map.of(
|
Map<String, Object> params = Map.of(
|
||||||
|
|||||||
Reference in New Issue
Block a user