Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Creative commons Attribution-NonCommercial license. NO WARRANTY IS GIVEN OR IMPLIED, USE AT YOUR OWN RISK.
  package base.jee.api.cassandra;
 import java.util.Map;
 import base.Command;
 public class Setup extends Command {
 	private CassandraAPI c;
 	public Setup(CassandraAPI c) {
 		this. = c;
 		if(c == null) {
 			throw new IllegalArgumentException("Invalid parameter: c");
 	protected void execute() throws IOException {
 		runIfPossible(s"create table audit_event (yyyymmdd text, uuid timeuuid, person_uuid timeuuid, first_name text, last_name text, level text, message text, ip text, primary key (yyyymmdd, uuid))");
 		runIfPossible(s"create table audit_type (audit_event_uuid timeuuid primary key, resource_uid text, resource_type text)");
 		runIfPossible(s"create table batch_load_info (uuid uuid, requestor uuid, executed bigint, primary key(uuid))");
 		runIfPossible(s"create table batch_load_result (uuid uuid, sort_order int, value text, primary key(uuid, sort_order))");
 		runIfPossible(s"create table base_group (uuid uuid primary key, name text, type int)");
 		runIfPossible(s"create index base_group_index1 on base_group (name)");
 		runIfPossible(s"create table group_member (person_uuid uuid, group_uuid uuid, joined bigint, primary key(person_uuid, group_uuid))");
 		runIfPossible(s"create table ip_location (part int, start bigint, end bigint, location bigint, primary key (part, start, end)) with clustering order by (start desc);\n");
 		runIfPossible(s"create table location (id bigint, country text, city text, latitude double, longitude double, primary key(id))");
 		runIfPossible(s"create table person (uuid timeuuid primary key, first_name text, last_name text, email text, username text, password text, last_auth bigint, last_auth_ip text, created bigint, updated bigint, expiry bigint)");
 		runIfPossible(s"create index person_index1 on person (email)");
 		runIfPossible(s"create index person_index2 on person (username)");
 		runIfPossible(s"create table person_setting (uuid uuid, name text, value text, primary key(uuid, name))");
 		runIfPossible(s"create table session_token (uid text primary key, person_uuid timeuuid, first_name text, last_name text, expiry bigint, roles text, created bigint)");
 		runIfPossible(s"create index session_token_index1 on session_token (person_uuid)");
 		runIfPossible(s"create table request_token (uid text primary key, person_uuid timeuuid, expiry bigint, type text, ip text, data text)");
 		runIfPossible(s"create table role (role text, resource text, uid text, person_uuid timeuuid, primary key(role, person_uuid, resource, uid))");
 		runIfPossible(s"create table setting (name text primary key, value text)");
 		runIfPossible(s"create table template (name text primary key)");
 		runIfPossible(s"create table template_resource (template text, resource text, content blob, isbinary boolean, primary key (template, resource))");
 		runIfPossible(s"create table throttle (key_value text primary key, attempts int, updated bigint)");
 		runIfPossible(s"create table update_notification (type text, updated bigint, uuid uuid, updator uuid, action text, uid text, delivered boolean, primary key(type, updated, uuid))");
 		runIfPossible(s"insert into base_group (uuid, name, type) values(" + ..toString() + ",'All users', 0)");
 		runIfPossible(s"insert into base_group (uuid, name, type) values(" + ..toString() + ",'Authenticated users', 0)");
 		Connection c = null;
 		PreparedStatement p = null;
 		try {
 			c = this..getDataSource().getConnection();
 			p = c.prepareStatement("create table email (uuid text primary key, to_address text, email text, retries bigint, attempt_at bigint, in_progress boolean)");
 		} catch(SQLException e) {
 		} finally {
 			if(p != null) { try { p.close(); } catch(SQLException e) {} }
 			if(c != null) { try { c.close(); } catch(SQLException e) {} }
 	private void runIfPossible(Session sString sql) {
 		try {
 		} catch(AlreadyExistsException e) {
 			// Do nothing
 		} catch(Exception e) {
 			if(!e.getMessage().contains("Index already exists")) {
 				throw e;
		return "{" +
		throw new IllegalArgumentException("Setup may not be instantiated with parameter map");
New to GrepCode? Check out our FAQ X