Fix

speedment · Oct 1, 2016 · ac91537 · ac91537
1 parent e11468a
commit ac91537
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/...e-core/src/main/java/com/speedment/runtime/core/component/SqlStreamSupplierComponent.java b/...e-core/src/main/java/com/speedment/runtime/core/component/SqlStreamSupplierComponent.java
@@ -13,9 +13,7 @@
  */
 public interface SqlStreamSupplierComponent extends StreamSupplierComponent {
 
-    public interface Support<ENTITY> {
-
-        String getSql();
+    public interface Support<ENTITY> {        
 
         ENTITY from(ResultSet rs);
 

diff --git a/...in/java/com/speedment/runtime/core/internal/component/SqlStreamSupplierComponentImpl.java b/...in/java/com/speedment/runtime/core/internal/component/SqlStreamSupplierComponentImpl.java
@@ -30,20 +30,24 @@
  */
 public class SqlStreamSupplierComponentImpl implements SqlStreamSupplierComponent {
 
-    private final Map<TableIdentifier, SqlStreamSupplierComponent.Support> supportMap;
+    private final Map<TableIdentifier, SqlStreamSupplierComponentImpl> supportMap;
 
     public SqlStreamSupplierComponentImpl() {
         this.supportMap = new ConcurrentHashMap<>();
     }
 
     @Override
     public <ENTITY> Stream<ENTITY> stream(TableIdentifier<ENTITY> tableIdentifier, StreamDecorator decorator) {
-        final SqlStreamSupplierComponent.Support support = supportMap.computeIfAbsent(tableIdentifier, this::makeSupport);
+        final SqlStreamSupplierComponentImpl support = supportMap.computeIfAbsent(tableIdentifier, this::makeSupport);
 
         return Stream.empty(); // Todo: Generate stream.
     }
 
-    private SqlStreamSupplierComponent.Support makeSupport(TableIdentifier<?> tableIdentifier) {
+    private SqlStreamSupplierComponentImpl makeSupport(TableIdentifier<?> tableIdentifier) {
+
+        SqlStreamSupplierComponent.Support externalSupport = injector....find()
+        SqlStreamSupplierComponentImpl support = new SqlStreamSupplierComponentImplSupport(externalSupport);
+
         // Calculate stuff from the TableIdentifier and some other components...
         return null;
     }