collect/src/main/java/.svn/text-base/TestResetCompute.java.svn-base

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;

import com.sagacloud.json.JSONObject;
import com.zillion.database.agent.ZillionAgent;

public class TestResetCompute {
	public static String database_name = "db_public";

	public static void main(String[] args) throws Exception {
		Configuration configuration = HBaseConfiguration.create();
		String zookeeper_connectionAddress = "zookeeper1:2181,zookeeper2:2181,zookeeper3:2181";
		int zookeeper_sessionTimeout = 300000;
		ZillionAgent agent = new ZillionAgent(configuration, zookeeper_connectionAddress, zookeeper_sessionTimeout);
		agent.Start();

		JSONObject Criteria = new JSONObject();
		JSONObject wrapperObject = new JSONObject();
		wrapperObject.put("QueryType", "delete");
		wrapperObject.put("Database", database_name);
		wrapperObject.put("Datatable", "fjd_0_computelog");
		wrapperObject.put("Criteria", Criteria);
		agent.Query(wrapperObject);

		Criteria = new JSONObject();
		wrapperObject = new JSONObject();
		wrapperObject.put("QueryType", "delete");
		wrapperObject.put("Database", database_name);
		wrapperObject.put("Datatable", "fjd_0_computedetail");
		wrapperObject.put("Criteria", Criteria);
		agent.Query(wrapperObject);

		Criteria = new JSONObject();
		wrapperObject = new JSONObject();
		wrapperObject.put("QueryType", "delete");
		wrapperObject.put("Database", database_name);
		wrapperObject.put("Datatable", "fjd_0_metercomputetime");
		wrapperObject.put("Criteria", Criteria);
		agent.Query(wrapperObject);

		Criteria = new JSONObject();
		wrapperObject = new JSONObject();
		wrapperObject.put("QueryType", "delete");
		wrapperObject.put("Database", database_name);
		wrapperObject.put("Datatable", "fjd_0_buildingcomputetime");
		wrapperObject.put("Criteria", Criteria);
		agent.Query(wrapperObject);

		JSONObject InsertObject = new JSONObject();
		InsertObject.put("building", "1101080001");
		InsertObject.put("compute_time", "20170101000000");
		InsertObject.put("first_compute_time", "20170101000000");
		wrapperObject = new JSONObject();
		wrapperObject.put("QueryType", "insert");
		wrapperObject.put("Database", database_name);
		wrapperObject.put("Datatable", "fjd_0_buildingcomputetime");
		wrapperObject.put("InsertObject", InsertObject);
		agent.Query(wrapperObject);

		agent.Stop();
	}

}