-
Notifications
You must be signed in to change notification settings - Fork 5
/
SqlTypeSource.java
30 lines (27 loc) · 1.05 KB
/
SqlTypeSource.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package edu.ie3.datamodel.io.source.sql;
import edu.ie3.datamodel.io.connectors.SqlConnector;
import edu.ie3.datamodel.io.naming.DatabaseNamingStrategy;
import edu.ie3.datamodel.io.source.TypeSource;
public class SqlTypeSource extends TypeSource {
public SqlTypeSource(
SqlConnector connector,
String schemaName,
DatabaseNamingStrategy databaseNamingStrategy
) {
super(new SqlDataSource(connector, schemaName, databaseNamingStrategy));
}
/*
public <T extends InputEntity> Stream<Map<String, String>> getSourceData(Class<T> entityClass) {
String query = createBaseQueryString(getSchemaName(), entityClass.getSimpleName());
try (PreparedStatement ps = connector.getConnection().prepareStatement(query)) {
return buildStreamByQuery(TimeBasedValue.class, a -> {}, ps);
} catch (SQLException e) {
return null;
}
}
@Override
protected Optional createEntity(Map<String, String> fieldToValues) {
return Optional.empty();
}
*/
}