@@ -0,0 +1,1377 @@
+package greenmoonsoftware.es.event.jdbcstore;%0A%0Aimport greenmoonsoftware.es.event.Event;%0A%0Aimport javax.sql.DataSource;%0Aimport java.io.IOException;%0Aimport java.sql.Connection;%0Aimport java.sql.PreparedStatement;%0Aimport java.sql.ResultSet;%0Aimport java.sql.SQLException;%0Aimport java.util.ArrayList;%0Aimport java.util.Collections;%0Aimport java.util.List;%0A%0Apublic class JdbcEventQuery %7B%0A    private final EventSerializer serializer;%0A    private final DataSource datasource;%0A    private final JdbcStoreConfiguration configuration;%0A%0A    public JdbcEventQuery(%0A            JdbcStoreConfiguration config,%0A            DataSource ds%0A    ) %7B%0A        configuration = config;%0A        datasource = ds;%0A        serializer = new ObjectEventSerializer();%0A    %7D%0A%0A    public List%3CEvent%3E getEvents() %7B%0A        try (Connection con = datasource.getConnection();%0A             PreparedStatement ps = con.prepareStatement(%22select * from %22 + configuration.getTablename() + %22 order by eventDateTime asc%22);%0A             ResultSet rs = ps.executeQuery()%0A        ) %7B%0A            List%3CEvent%3E events = new ArrayList%3C%3E();%0A            while(rs.next()) %7B%0A                events.add(serializer.deserialize(rs.getBinaryStream(%22data%22)));%0A            %7D%0A            return Collections.unmodifiableList(events);%0A        %7D catch (SQLException %7C IOException e) %7B%0A            throw new RuntimeException(e);%0A        %7D%0A    %7D%0A%0A%7D%0A

Add JdbcEventQuery