package examples;

import com.xxdb.DBConnection;
import com.xxdb.streaming.client.ThreadedClient;

import java.io.IOException;

public class ThreadedClientDemo {
    private static DBConnection conn = new DBConnection();
    public static String host = "localhost";
    public static Integer port = 8848;
    public static ThreadedClient client;
    public static Integer subscribePort = 8892;


    public static void main(String[] args) throws IOException, InterruptedException {
        createStreamTable();
        ThreadedClient client = new ThreadedClient(subscribePort);
        client.subscribe(host, port, "Trades", new MyHandler(), 0);
        Thread.sleep(5 * 1000);
        //shutdown the client
        client.close();
    }

    public static void createStreamTable() throws IOException {
        conn.connect(host, port);
        conn.login("admin", "123456", false);
        try{
            conn.run("dropStreamTable(\"Trades\")");
        }catch (Exception e){
            System.out.println(e.getMessage());
        }
        conn.run("share streamTable(30000:0,`id`time`sym`qty`price,[INT,TIMESTAMP,SYMBOL,INT,DOUBLE]) as Trades\n");
        conn.run("data=table(1..1000 as id, now()+1..1000 as time, take(`aaa,1000) as sym," +
                "rand(100..1000, 1000) as qty,rand(100.0, 1000) as price)");
        conn.run("Trades.tableInsert(data)");
    }

}