@@ -0,0 +1,1847 @@
+/*%0A*  Copyright (c) 2017, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.%0A*%0A*  WSO2 Inc. licenses this file to you under the Apache License,%0A*  Version 2.0 (the %22License%22); you may not use this file except%0A*  in compliance with the License.%0A*  You may obtain a copy of the License at%0A*%0A*    http://www.apache.org/licenses/LICENSE-2.0%0A*%0A* Unless required by applicable law or agreed to in writing,%0A* software distributed under the License is distributed on an%0A* %22AS IS%22 BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY%0A* KIND, either express or implied.  See the License for the%0A* specific language governing permissions and limitations%0A* under the License.%0A*/%0Apackage org.wso2.siddhi.extension.table.rdbms;%0A%0Aimport org.wso2.siddhi.core.table.record.RecordIterator;%0Aimport org.wso2.siddhi.extension.table.rdbms.util.RDBMSTableUtils;%0A%0Aimport java.io.IOException;%0Aimport java.sql.Connection;%0Aimport java.sql.PreparedStatement;%0Aimport java.sql.ResultSet;%0A%0Apublic class RDBMSIterator implements RecordIterator%3CObject%5B%5D%3E %7B%0A%0A    private ResultSet rs;%0A    private PreparedStatement stmt;%0A    private Connection conn;%0A%0A    @Override%0A    public boolean hasNext() %7B%0A        return false;%0A    %7D%0A%0A    @Override%0A    public Object%5B%5D next() %7B%0A        return new Object%5B0%5D;%0A    %7D%0A%0A    @Override%0A    public void remove() %7B%0A%0A    %7D%0A%0A    @Override%0A    public void close() throws IOException %7B%0A        RDBMSTableUtils.cleanupConnection(this.rs, this.stmt, this.conn);%0A        this.rs = null;%0A        this.stmt = null;%0A        this.conn = null;%0A    %7D%0A%0A    @Override%0A    protected void finalize() throws Throwable %7B%0A            /* in the unlikely case, this iterator does not go to the end,%0A             * we have to make sure the connection is cleaned up */%0A        RDBMSTableUtils.cleanupConnection(this.rs, this.stmt, this.conn);%0A        super.finalize();%0A    %7D%0A%0A%7D%0A

Add iterator (initial commit)