package neo.helper.db;

import java.sql.SQLException;
import java.util.HashMap;

import neo.db.RawClass;
import neo.db.tables.cameras;
import neo.db.tables.servers;
import neo.db.tables.test;
import neo.db.tables.users;
import net.java.ao.EntityManager;
import net.java.ao.builder.EntityManagerBuilder;

public class ormFlushTest {

    /**
     * @param args
     */
    public static EntityManager manager;
    public static void main(String[] args) {
        System.out.println("Start");
        manager = EntityManagerBuilder.url("jdbc:mysql://192.168.253.32/neovsp").username("neodev").password("devnow1").boneCP().fieldNameConverter(new net.java.ao.schema.UnderscoreFieldNameConverter(false)).build();
        //manager = new EntityManager("jdbc:mysql://192.168.253.32/neovsp", "neodev", "devnow1");
        //manager.setFieldNameConverter(new net.java.ao.schema.UnderscoreFieldNameConverter(false));

        for(int i=0;i<1;i++)
        {
            Test t= new Test(i);
        }
    }
    static class Test extends Thread
    {
        int ii;
        public Test(int i) {
            ii=i;
            start();

        }
        public void run()
        {
            for(int i=0;i<200;i++)
            {
                cameras[] cams=null;
                try {
                    servers[] servers_arr = manager.find(servers.class, "name='nctest.neo.it'");

                    manager.flush(servers_arr);
                    System.out.println("Server Length "+servers_arr.length);
                    if(servers_arr.length>0)
                    {
                        cams = servers_arr[0].getCameras();
                        manager.flush(cams);
                        System.out.println("Cams Length "+cams.length);
                    }


                } catch (SQLException e) {
                    e.printStackTrace();
                }
                try {
                    Thread.sleep(3000);
                } catch (Exception e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
}