package examples;

import com.xxdb.*;
import com.xxdb.data.*;
import com.xxdb.io.ProgressListener;
import java.io.IOException;

public class ReadDataDemo {

 private static DBConnection conn = new DBConnection();
 private static String hostname = "localhost";
 private static int port = 8848;
 private static String username = "admin";
 private static String password = "123456";

 static {
 try {
 conn.connect(hostname, port, username, password);
 } catch (IOException e) {
 e.printStackTrace();
 }
 }

 public static void main(String[] args) throws IOException {
 basicTableRead();
 batchRead();
 }

 public static void basicTableRead() throws IOException {

 conn.run("t = table(10000:0,`cstring`cint`ctimestamp`cdouble,[STRING,INT,TIMESTAMP,DOUBLE])\n" +
 "share t as sharedTable");
 conn.run(String.format("insert into sharedTable values(['IBM', 100, 2012年06月13日 13:30:10.008, 3.14])"));
 conn.run(String.format("insert into sharedTable values(['GOOG', 200, 2012年06月13日 13:30:10.008, 3.14])"));
 conn.run(String.format("insert into sharedTable values(['YHOO', 300, 2012年06月13日 13:30:10.008, 3.14])"));
 conn.run(String.format("insert into sharedTable values(['MSFT', 400, 2012年06月13日 13:30:10.008, 3.14])"));
 conn.run(String.format("insert into sharedTable values(['FB', 500, 2012年06月13日 13:30:10.008, 3.14])"));
 conn.run(String.format("insert into sharedTable values(['HP', 600, 2012年06月13日 13:30:10.008, 3.14])"));
 conn.run(String.format("insert into sharedTable values(['IBM', 700, 2012年06月13日 13:30:10.008, 3.14])"));

 BasicTable table = (BasicTable) conn.run("select * from sharedTable");

 // get a column by index start at 0
 Vector firstColumn = table.getColumn(0);
 System.out.println("firstColumn: " + firstColumn.getString());
 Vector secondColumn = table.getColumn(1);
 System.out.println("secondColumn: " + secondColumn.getString());

 // get a column by column name
 Vector cstringColumn = table.getColumn("cstring");
 System.out.println("cstringColumn: " + cstringColumn.getString());

 // get the string
 String tableString = table.getString();
 System.out.println("tableString: \n" + tableString);

 // get the table slices
 Table subTableRange = table.getSubTable(0, 1);
 System.out.println("subTableRange: \n" + subTableRange.getString());

 }

 public static void batchRead() throws IOException {

 EntityBlockReader v = (EntityBlockReader)conn.run("table(1..22486 as id)",(ProgressListener) null,4,4,10000);
 BasicTable data = (BasicTable)v.read();
 while(v.hasNext()){
 BasicTable t = (BasicTable)v.read();
 data = data.combine(t);
 }
 System.out.println(data.getString());
 }

}