import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.*;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
public class createTable
{
public static void main(String[] args)
{
DB db = new DB();
Connection conn=db.dbConnect(
"jdbc:qed:mynewdb://localhost:1925", "p");
db.createTables(conn);
}
}//createTable
class DB
{
public DB() {}
public Connection dbConnect(String db_connect_string,
String db_userid)
{
try
{
Class.forName("com.quadcap.jdbc.JdbcDriver");
java.util.Properties p = new java.util.Properties();
p.setProperty("create", "true");
java.sql.Connection conn =
java.sql.DriverManager.getConnection("jdbc:qed:mynewdb", p);
return conn;
}
catch (Exception e)
{
e.printStackTrace();
return null;
}
} //Connection dbConnect
//Employee table
public void createTables(Connection conn)
{
String query;
Statement stmt;
try
{
query="create table cust_profile " +
"(name varchar(32), " +
"id varchar(50), " +
"telephoneNo varchar(50), " +
"email varchar(50))";
stmt = conn.createStatement();
stmt.executeUpdate(query);
stmt.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
} //createTables
public void createJobRoles(Connection conn)
{
String query;
Statement stmt;
try
{
query="create table Job_roles " +
"(JOB_ID INTEGER NOT NULL, " +
"job_title varchar(32), " +
"salary_class varchar(50), " +
"job_description varchar(50), " +;
"primary key(JOB_ID))";
stmt = conn.createStatement();
stmt.executeUpdate(query);
stmt.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
public void EmployeeNameSearch(Object args) {
List names = Arrays.asList(args);
Collections.sort(names); //sort ArrayList required for binarySearch
BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
while (true) {
String option = stdin.readLine();
if (cust_profile.binarySearch(names.toArray(),option.toLowerCase())== -1)
{
System.out.println("Not found in database: ");
System.out.println("Name: " + option );
}
}
}; //namesSearch
};
query="create table cust_profile " +
"(name varchar(32), " +
"id varchar(50), " +
"telephoneNo varchar(50), " +
"email varchar(50), " +
"JOB_ID integer, " +
"foreign key (JOB_ID) references Job_roles (JOB_ID);
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.*;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
public class createTable
{
public static void main(String[] args)
{
DB db = new DB();
Connection conn=db.dbConnect(
"jdbc:qed:mynewdb://localhost:1925", "p");
db.createTables(conn);
}
}
class DB
{
public DB() {}
public Connection dbConnect(String db_connect_string,
String db_userid)
{
try
{
Class.forName("com.quadcap.jdbc.JdbcDriver");
java.util.Properties p = new java.util.Properties();
p.setProperty("create", "true");
java.sql.Connection conn =
java.sql.DriverManager.getConnection("jdbc:qed:mynewdb", p);
return conn;
}
catch (Exception e)
{
e.printStackTrace();
return null;
}
}
//Employee table
public void createTables(Connection conn)
{
String query;
Statement stmt = null;
try
{
query="create table employees " +
"(name varchar(32), " +
"id varchar(50), " +
"telephoneNo varchar(50), " +
"email varchar(50), " +
"JOB_ID integer, " +
"foreign key (JOB_ID) references Job_roles (JOB_ID))";
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('John Doe', '1', '5555999944', 'Something@mail.com')");
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('Neil Mayhem', '2', '555588888', 'sth@mail.com')");
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('Alice Lovelace', '3', '6666999944', 'alice@mail.com')");
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('Jay Something', '4', '666669999', 'mail@mail.com')");
stmt = conn.createStatement();
stmt.executeUpdate(query);
stmt.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
} //createTables
public void createJobRoles(Connection conn)
{
String query;
Statement stmt = null;
try
{
query="create table Job_roles " +
"(JOB_ID INTEGER NOT NULL, " +
"job_title varchar(32), " +
"salary_class varchar(50), " +
"job_description varchar(50), " +
"primary key(JOB_ID))";
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (1, 'Garden Worker', '4', 'Cultivates and cares for plants')");
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (2, 'Security Guard', '4', 'Takes care of security')");
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (3, 'Stage Hypnotist', '2', 'Hypnotizes people on stage')");
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (4, 'Amusement Park Guide', '3', 'Guides people through an amusement park')");
stmt = conn.createStatement();
stmt.executeUpdate(query);
stmt.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
public void EmployeeNameSearch(Object args) {
List names = Arrays.asList(args);
List not = new ArrayList();
//Collections.sort(names);
PreparedStatement ps = null;
BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
while (true) {
String option = stdin.readLine();
for (String name : names) {
ps.setString(1, name);
ResultSet rs = ps.executeQuery();
if (rs.next()) {
// name in db
}
else
{
System.out.println(name + "not in db!");
not.add(name);
}
}
}
}
};
query="create table Job_roles " +
"(JOB_ID INTEGER NOT NULL, " +
"job_title varchar(32), " +
"salary_class varchar(50), " +
"job_description varchar(50), " +
"primary key(JOB_ID), " +
"foreign key (JOB_ID) references Job_roles (JOB_ID))";
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.*;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
public class createTable
{
public static void main(String[] args)
{
DB db = new DB();
Connection conn=db.dbConnect(
"jdbc:qed:mynewdb://localhost:1925", "p");
db.createTables(conn);
}
}
class DB
{
public DB() {}
public Connection dbConnect(String db_connect_string,
String db_userid)
{
try
{
Class.forName("com.quadcap.jdbc.JdbcDriver");
java.util.Properties p = new java.util.Properties();
p.setProperty("create", "true");
java.sql.Connection conn =
java.sql.DriverManager.getConnection("jdbc:qed:mynewdb", p);
return conn;
}
catch (Exception e)
{
e.printStackTrace();
return null;
}
}
//Employee table
public void createTables(Connection conn)
{
String query;
Statement stmt = null;
try
{
/*
query="create table employees " +
"(name varchar(32), " +
"id varchar(50), " +
"telephoneNo varchar(50), " +
"email varchar(50), " +
"JOB_ID integer, " +
"foreign key (JOB_ID) references Job_roles (JOB_ID))";
*/
CREATE TABLE employees (
name TEXT NOT NULL,
id TEXT NOT NULL,
telephone_no TEXT NOT NULL,
email TEXT NOT NULL
);
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('John Doe', '1', '5555999944', 'Something@mail.com')");
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('Neil Mayhem', '2', '555588888', 'sth@mail.com')");
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('Alice Lovelace', '3', '6666999944', 'alice@mail.com')");
stmt.executeUpdate("INSERT INTO employees " +
"VALUES ('Jay Something', '4', '666669999', 'mail@mail.com')");
stmt = conn.createStatement();
stmt.executeUpdate(query);
stmt.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
} //createTables
public void createJobRoles(Connection conn)
{
String query;
Statement stmt = null;
try
{
/*
query="create table Job_roles " +
"(JOB_ID INTEGER NOT NULL, " +
"job_title varchar(32), " +
"salary_class varchar(50), " +
"job_description varchar(50), " +
"primary key(JOB_ID), " +
"foreign key (JOB_ID) references Job_roles (JOB_ID))";
*/
CREATE TABLE Job_roles (
EMPLOYEE_ID BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY,
JOB_TITLE TEXT NOT NULL,
SALARY CLASS BIGINT NOT NULL,
JOB_DESCRIPTION TEXT NOT NULL
);
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (1, 'Garden Worker', '4', 'Cultivates and cares for plants')");
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (2, 'Security Guard', '4', 'Takes care of security')");
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (3, 'Stage Hypnotist', '2', 'Hypnotizes people on stage')");
stmt.executeUpdate("INSERT INTO Job_roles " +
"VALUES (4, 'Amusement Park Guide', '3', 'Guides people through an amusement park')");
stmt = conn.createStatement();
stmt.executeUpdate(query);
stmt.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
public void EmployeeNameSearch(Object args) {
List names = Arrays.asList(args);
List not = new ArrayList();
//Collections.sort(names);
PreparedStatement ps = null;
BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
while (true) {
String option = stdin.readLine();
for (String name : names) {
ps.setString(1, name);
ResultSet rs = ps.executeQuery();
if (rs.next()) {
// name in db
}
else
{
System.out.println(name + "not in db!");
not.add(name);
}
}
}
}
};
Hopefully, I didn't leave any syntax errors in the code... it is untested.
Regards,
Lynn
Open in new window