Lazy Loading in benutzerdefinierten ORM

Question

Ich arbeite derzeit an der Entwicklung einer einfachen Java-Webanwendung ohne Verwendung eines ORM.

Es ist eine geschichtete Architektur. Ich verwende Annotationen, um die Spalten meiner Domain-Klasse in meine Persistenz-Ebene zu "mappen", in der sich die Repositories befinden.

Meine DefaultRepository verwendet Reflektion, um die Feldnamen zu erhalten und die Abfragen zu erstellen. Ich benutze nur dieses, anstatt ein separates für jede Domäne (wie Benutzer, Bestellung, Produkt) zu machen.

Es sieht wie folgt aus:

Repository:

public abstract class DefaultRepository <TYPE extends DefaultDomain<TYPE>>{ 

    public int insert(Connection con, TYPE entity){}; 
    public int update (Connection con, TYPE entity){}; 
    public int delete (Connection con, TYPE entity){}; 
    public int findById(Connection con, int id){}; 
    ... 

} 

ich faul Laden implementieren möchten nur die Aufträge jedes Benutzers zu laden, wenn angefordert. Dies geschieht vorzugsweise im Repository in der , wo ich die Ergebnismenge auf meine TYPE (Domain-Klasse) zuordnen.

Wie würde ich diese Fremdschlüsselbeziehung/eins zu vielen/vielen zu einem allgemein implementieren?

Eine Idee war, eine Annotation mit dem spezifischen Repository zu machen und dann die findAll() Methode aufzurufen, wenn die Orderliste aufgerufen wird.

Zum Beispiel:

public class Order extends DefaultDomain{ 
    @ManyToOne(repository=UserRepository.class) 
    private User user; 

} 

Ist das der richtige Weg? Gibt es einen anderen/besseren Ansatz?

Answer 1

Ich entwickelte eine Lösung wie diese, die ich in meinem Fall die mit CGLib kombiniert Proxy Design Pattern verwendet.

Im Grunde werden Sie Ihre Objekte durch eine Factory instanziieren, die Proxies generieren wird, die persistente Objekte von ORM zurückgeben und automatisch Listener erstellen, die die Methoden verwalten, die Sie verwalten möchten. Ich hoffe, das hilft dir.

https://docs.oracle.com/javase/7/docs/api/java/lang/reflect/Proxy.html

public interface PersonInterface{ 
    public String getName(); 
    public void setName(String name); 
    public int findById(int id); 
} 
public static class Person implements PersonInterface{ 

    String name; 

    public String getName() { 
     return name; 
    } 

    public void setName(String name) { 
     this.name = name; 
    } 

    @Override 
    public int findById(int id) { 
     return id; 
    } 
} 
public static class ProxyPersonImpl implements java.lang.reflect.InvocationHandler{ 

    private PersonInterface person; 

    public ProxyPersonImpl(Person person) { 
     this.person = person; 
    } 
    public static PersonInterface newInstance(Person obj) { 
     return (PersonInterface) java.lang.reflect.Proxy.newProxyInstance(
      obj.getClass().getClassLoader(), 
      obj.getClass().getInterfaces(), 
      new ProxyPersonImpl(obj)); 
    }  
    @Override 
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { 
     System.out.println("My Proxy listen this method invocation:"+method.getName()); 
     return method.invoke(person, args); 
    } 
} 

public class ProxyTest { 
    public static void main(String[] args) { 
     PersonInterface p = ProxyPersonImpl.newInstance(new Person()); 
     p.setName("Name seted"); 
     String name = p.getName(); 
     System.out.println(name); 
     int i = p.findById(1); 
     System.out.println(i); 
    } 
} 
class Repository { 
    Connection con; 
    public Repository() { 
     con = ConnectionFactory.getConnection(); 
    } 

    public Person findById(int id) { 
     Person p = new Person(); 
     try { 
      PreparedStatement statement = con.prepareStatement("Your sql here"); 
      ResultSet result = statement.executeQuery();     
      if(result.next()) { 
       p.setName(result.getString("Name")); 
      }   
     } catch (SQLException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 

     return p; 
    }  
} 

static class ConnectionFactory { 
    private static Connection con; 

    public static Connection getConnection() { 
     if(con == null) { 
      //create connection here 

     } 
     return con; 
    }  
}