package output; import output.ConnectionFactory; import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException; public class ComputeChangeset{ static Connection conn;public static void openConn() throws SQLException{ conn = ConnectionFactory.getConnection(); } public static void closeConn() throws SQLException{ conn.close();} public static boolean nonNull(Object value){ return value != null ; } public static String removeBlankCaractere(String s){ String v = ""; for(int i=0;i"); uri = uri.replaceAll("\\s+",""); return uri; } public static class Tuple_TOPICS { public Tuple_TOPICS(java.lang.Integer TOPICID,java.lang.String TOPICNAME,java.lang.String URI,java.lang.Integer PARENTID) { this.TOPICID = TOPICID; this.TOPICNAME = TOPICNAME; this.URI = URI; this.PARENTID = PARENTID; } public Tuple_TOPICS( ){ } public java.lang.Integer TOPICID; public java.lang.String TOPICNAME; public java.lang.String URI; public java.lang.Integer PARENTID; } public static Tuple_TOPICS[] obterTuplesTOPICS(ResultSet rs, int rowCount){ Tuple_TOPICS[] listaTOPICS = null; try { listaTOPICS = new Tuple_TOPICS[rowCount]; Tuple_TOPICS tuple = null; int i = 0; while(rs.next()) { tuple = new Tuple_TOPICS(); tuple.TOPICID = (rs.getObject("TOPICID") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("TOPICID"))) : null;tuple.TOPICNAME = (rs.getObject("TOPICNAME") != null) ? new java.lang.String((java.lang.String)(rs.getObject("TOPICNAME"))) : null;tuple.URI = (rs.getObject("URI") != null) ? new java.lang.String((java.lang.String)(rs.getObject("URI"))) : null;tuple.PARENTID = (rs.getObject("PARENTID") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("PARENTID"))) : null; listaTOPICS[i] = tuple; i++;} } catch (SQLException e){ }return listaTOPICS; }public static Tuple_TOPICS[] ObtainTuples_TOPICS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_TOPICS[] listaTOPICS = null; String sqlConsulta = "SELECT * FROM TOPICS"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaTOPICS = obterTuplesTOPICS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } for(Tuple_TOPICS tuple: listaTOPICS){ RDF_State_TOPICS(tuple); } return listaTOPICS; } public static Tuple_TOPICS[] ObtainTuplesA_TOPICS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_TOPICS[] listaTOPICS = null; String sqlConsulta = "SELECT TOPICS.* FROM A_TOPICS, TOPICS WHERE A_TOPICS.TOPICID = TOPICS.TOPICID "; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaTOPICS = obterTuplesTOPICS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaTOPICS; } public static void AddTupleA_TOPICS(Tuple_TOPICS t){ String sqlConsulta = ""; sqlConsulta = "INSERT INTO A_TOPICS(TOPICID, TOPICNAME, URI, PARENTID) VALUES (?, ?, ?, ?)";try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); pstmt.setObject(1, t.TOPICID, 4); pstmt.setObject(2, t.TOPICNAME, 12); pstmt.setObject(3, t.URI, 12); pstmt.setObject(4, t.PARENTID, 4); pstmt.executeUpdate(); } catch (SQLException e) { } } public static void ObtainAffectedTuples_TOPICS(java.lang.Integer TOPICID, java.lang.String TOPICNAME, java.lang.String URI, java.lang.Integer PARENTID){ Tuple_TOPICS r = new Tuple_TOPICS(TOPICID, TOPICNAME, URI, PARENTID); AddTupleA_TOPICS(r); try { Tuple_TOPICS[] Q1 = null; Q1 = ObtainReferencedTuples_topics_ibfk_1(r); if (Q1 != null) { for (Tuple_TOPICS t : Q1) { AddTupleA_TOPICS(t); } } } catch (SQLException e) {} } public static void createTempTableTOPICS(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_TOPICS;\n" + "CREATE TEMP TABLE A_TOPICS\n" + "(LIKE TOPICS INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static String GenerateURI_CCA1(Tuple_PERSONS rnew) { String uri = removeBlankCaractere(""); uri = uri.replaceAll("\\s+",""); return uri; } public static class Tuple_PERSONS { public Tuple_PERSONS(java.lang.Integer PERID,java.lang.String TYPE,java.lang.String FIRSTNAME,java.lang.String LASTNAME,java.lang.String ADDRESS,java.lang.String EMAIL,java.lang.String HOMEPAGE,java.lang.String PHONE,java.lang.String URI,java.lang.String PHOTO) { this.PERID = PERID; this.TYPE = TYPE; this.FIRSTNAME = FIRSTNAME; this.LASTNAME = LASTNAME; this.ADDRESS = ADDRESS; this.EMAIL = EMAIL; this.HOMEPAGE = HOMEPAGE; this.PHONE = PHONE; this.URI = URI; this.PHOTO = PHOTO; } public Tuple_PERSONS( ){ } public java.lang.Integer PERID; public java.lang.String TYPE; public java.lang.String FIRSTNAME; public java.lang.String LASTNAME; public java.lang.String ADDRESS; public java.lang.String EMAIL; public java.lang.String HOMEPAGE; public java.lang.String PHONE; public java.lang.String URI; public java.lang.String PHOTO; } public static Tuple_PERSONS[] obterTuplesPERSONS(ResultSet rs, int rowCount){ Tuple_PERSONS[] listaPERSONS = null; try { listaPERSONS = new Tuple_PERSONS[rowCount]; Tuple_PERSONS tuple = null; int i = 0; while(rs.next()) { tuple = new Tuple_PERSONS(); tuple.PERID = (rs.getObject("PERID") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("PERID"))) : null;tuple.TYPE = (rs.getObject("TYPE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("TYPE"))) : null;tuple.FIRSTNAME = (rs.getObject("FIRSTNAME") != null) ? new java.lang.String((java.lang.String)(rs.getObject("FIRSTNAME"))) : null;tuple.LASTNAME = (rs.getObject("LASTNAME") != null) ? new java.lang.String((java.lang.String)(rs.getObject("LASTNAME"))) : null;tuple.ADDRESS = (rs.getObject("ADDRESS") != null) ? new java.lang.String((java.lang.String)(rs.getObject("ADDRESS"))) : null;tuple.EMAIL = (rs.getObject("EMAIL") != null) ? new java.lang.String((java.lang.String)(rs.getObject("EMAIL"))) : null;tuple.HOMEPAGE = (rs.getObject("HOMEPAGE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("HOMEPAGE"))) : null;tuple.PHONE = (rs.getObject("PHONE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("PHONE"))) : null;tuple.URI = (rs.getObject("URI") != null) ? new java.lang.String((java.lang.String)(rs.getObject("URI"))) : null;tuple.PHOTO = (rs.getObject("PHOTO") != null) ? new java.lang.String((java.lang.String)(rs.getObject("PHOTO"))) : null; listaPERSONS[i] = tuple; i++;} } catch (SQLException e){ }return listaPERSONS; }public static Tuple_PERSONS[] ObtainTuples_PERSONS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PERSONS[] listaPERSONS = null; String sqlConsulta = "SELECT * FROM PERSONS"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPERSONS = obterTuplesPERSONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } for(Tuple_PERSONS tuple: listaPERSONS){ RDF_State_PERSONS(tuple); } return listaPERSONS; } public static Tuple_PERSONS[] ObtainTuplesA_PERSONS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PERSONS[] listaPERSONS = null; String sqlConsulta = "SELECT PERSONS.* FROM A_PERSONS, PERSONS WHERE A_PERSONS.PERID = PERSONS.PERID "; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPERSONS = obterTuplesPERSONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaPERSONS; } public static void AddTupleA_PERSONS(Tuple_PERSONS t){ String sqlConsulta = ""; sqlConsulta = "INSERT INTO A_PERSONS(PERID, TYPE, FIRSTNAME, LASTNAME, ADDRESS, EMAIL, HOMEPAGE, PHONE, URI, PHOTO) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); pstmt.setObject(1, t.PERID, 4); pstmt.setObject(2, t.TYPE, 12); pstmt.setObject(3, t.FIRSTNAME, 12); pstmt.setObject(4, t.LASTNAME, 12); pstmt.setObject(5, t.ADDRESS, 12); pstmt.setObject(6, t.EMAIL, 12); pstmt.setObject(7, t.HOMEPAGE, 12); pstmt.setObject(8, t.PHONE, 12); pstmt.setObject(9, t.URI, 12); pstmt.setObject(10, t.PHOTO, 12); pstmt.executeUpdate(); } catch (SQLException e) { } } public static void ObtainAffectedTuples_PERSONS(java.lang.Integer PERID, java.lang.String TYPE, java.lang.String FIRSTNAME, java.lang.String LASTNAME, java.lang.String ADDRESS, java.lang.String EMAIL, java.lang.String HOMEPAGE, java.lang.String PHONE, java.lang.String URI, java.lang.String PHOTO){ Tuple_PERSONS r = new Tuple_PERSONS(PERID, TYPE, FIRSTNAME, LASTNAME, ADDRESS, EMAIL, HOMEPAGE, PHONE, URI, PHOTO); AddTupleA_PERSONS(r); } public static void createTempTablePERSONS(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_PERSONS;\n" + "CREATE TEMP TABLE A_PERSONS\n" + "(LIKE PERSONS INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static class Tuple_REL_PAPER_TOPIC { public Tuple_REL_PAPER_TOPIC(java.lang.Integer PAPERID,java.lang.Integer TOPICID,java.lang.Integer RELATIONTYPE) { this.PAPERID = PAPERID; this.TOPICID = TOPICID; this.RELATIONTYPE = RELATIONTYPE; } public Tuple_REL_PAPER_TOPIC( ){ } public java.lang.Integer PAPERID; public java.lang.Integer TOPICID; public java.lang.Integer RELATIONTYPE; } public static void ObtainAffectedTuples_REL_PAPER_TOPIC(java.lang.Integer PAPERID, java.lang.Integer TOPICID, java.lang.Integer RELATIONTYPE){ Tuple_REL_PAPER_TOPIC r = new Tuple_REL_PAPER_TOPIC(PAPERID, TOPICID, RELATIONTYPE); try { Tuple_PERSONS[] Q1 = null; Q1 = ObtainReferencedTuples_rel_paper_topic_ibfk_1_rel_person_paper_ibfk_2_rel_person_paper_ibfk_1(r); if (Q1 != null) { for (Tuple_PERSONS t : Q1) { AddTupleA_PERSONS(t); } } } catch (SQLException e) {}try { Tuple_PAPERS[] Q1 = null; Q1 = ObtainReferencedTuples_rel_paper_topic_ibfk_1(r); if (Q1 != null) { for (Tuple_PAPERS t : Q1) { AddTupleA_PAPERS(t); } } } catch (SQLException e) {} } public static void createTempTableREL_PAPER_TOPIC(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_PERSONS;\n" + "CREATE TEMP TABLE A_PERSONS\n" + "(LIKE PERSONS INCLUDING DEFAULTS );\n"; sqlConsulta += "DROP TABLE IF EXISTS A_PAPERS;\n" + "CREATE TEMP TABLE A_PAPERS\n" + "(LIKE PAPERS INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static String GenerateURI_CCA3(Tuple_ORGANIZATIONS rnew) { String uri = removeBlankCaractere(""); uri = uri.replaceAll("\\s+",""); return uri; } public static String GenerateURI_CCA4(Tuple_ORGANIZATIONS rnew) { String uri = removeBlankCaractere(""); uri = uri.replaceAll("\\s+",""); return uri; } public static class Tuple_ORGANIZATIONS { public Tuple_ORGANIZATIONS(java.lang.Integer ORGID,java.lang.String TYPE,java.lang.String NAME,java.lang.String ADDRESS,java.lang.String LOCATION,java.lang.String POSTCODE,java.lang.String COUNTRY,java.lang.String URI,java.lang.Integer BELONGSTO,java.lang.String HOMEPAGE) { this.ORGID = ORGID; this.TYPE = TYPE; this.NAME = NAME; this.ADDRESS = ADDRESS; this.LOCATION = LOCATION; this.POSTCODE = POSTCODE; this.COUNTRY = COUNTRY; this.URI = URI; this.BELONGSTO = BELONGSTO; this.HOMEPAGE = HOMEPAGE; } public Tuple_ORGANIZATIONS( ){ } public java.lang.Integer ORGID; public java.lang.String TYPE; public java.lang.String NAME; public java.lang.String ADDRESS; public java.lang.String LOCATION; public java.lang.String POSTCODE; public java.lang.String COUNTRY; public java.lang.String URI; public java.lang.Integer BELONGSTO; public java.lang.String HOMEPAGE; } public static Tuple_ORGANIZATIONS[] obterTuplesORGANIZATIONS(ResultSet rs, int rowCount){ Tuple_ORGANIZATIONS[] listaORGANIZATIONS = null; try { listaORGANIZATIONS = new Tuple_ORGANIZATIONS[rowCount]; Tuple_ORGANIZATIONS tuple = null; int i = 0; while(rs.next()) { tuple = new Tuple_ORGANIZATIONS(); tuple.ORGID = (rs.getObject("ORGID") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("ORGID"))) : null;tuple.TYPE = (rs.getObject("TYPE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("TYPE"))) : null;tuple.NAME = (rs.getObject("NAME") != null) ? new java.lang.String((java.lang.String)(rs.getObject("NAME"))) : null;tuple.ADDRESS = (rs.getObject("ADDRESS") != null) ? new java.lang.String((java.lang.String)(rs.getObject("ADDRESS"))) : null;tuple.LOCATION = (rs.getObject("LOCATION") != null) ? new java.lang.String((java.lang.String)(rs.getObject("LOCATION"))) : null;tuple.POSTCODE = (rs.getObject("POSTCODE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("POSTCODE"))) : null;tuple.COUNTRY = (rs.getObject("COUNTRY") != null) ? new java.lang.String((java.lang.String)(rs.getObject("COUNTRY"))) : null;tuple.URI = (rs.getObject("URI") != null) ? new java.lang.String((java.lang.String)(rs.getObject("URI"))) : null;tuple.BELONGSTO = (rs.getObject("BELONGSTO") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("BELONGSTO"))) : null;tuple.HOMEPAGE = (rs.getObject("HOMEPAGE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("HOMEPAGE"))) : null; listaORGANIZATIONS[i] = tuple; i++;} } catch (SQLException e){ }return listaORGANIZATIONS; }public static Tuple_ORGANIZATIONS[] ObtainTuples_ORGANIZATIONS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_ORGANIZATIONS[] listaORGANIZATIONS = null; String sqlConsulta = "SELECT * FROM ORGANIZATIONS"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaORGANIZATIONS = obterTuplesORGANIZATIONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } for(Tuple_ORGANIZATIONS tuple: listaORGANIZATIONS){ RDF_State_ORGANIZATIONS(tuple); } return listaORGANIZATIONS; } public static Tuple_ORGANIZATIONS[] ObtainTuplesA_ORGANIZATIONS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_ORGANIZATIONS[] listaORGANIZATIONS = null; String sqlConsulta = "SELECT ORGANIZATIONS.* FROM A_ORGANIZATIONS, ORGANIZATIONS WHERE A_ORGANIZATIONS.ORGID = ORGANIZATIONS.ORGID "; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaORGANIZATIONS = obterTuplesORGANIZATIONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaORGANIZATIONS; } public static void AddTupleA_ORGANIZATIONS(Tuple_ORGANIZATIONS t){ String sqlConsulta = ""; sqlConsulta = "INSERT INTO A_ORGANIZATIONS(ORGID, TYPE, NAME, ADDRESS, LOCATION, POSTCODE, COUNTRY, URI, BELONGSTO, HOMEPAGE) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); pstmt.setObject(1, t.ORGID, 4); pstmt.setObject(2, t.TYPE, 12); pstmt.setObject(3, t.NAME, 12); pstmt.setObject(4, t.ADDRESS, 12); pstmt.setObject(5, t.LOCATION, 12); pstmt.setObject(6, t.POSTCODE, 12); pstmt.setObject(7, t.COUNTRY, 12); pstmt.setObject(8, t.URI, 12); pstmt.setObject(9, t.BELONGSTO, 4); pstmt.setObject(10, t.HOMEPAGE, 12); pstmt.executeUpdate(); } catch (SQLException e) { } } public static void ObtainAffectedTuples_ORGANIZATIONS(java.lang.Integer ORGID, java.lang.String TYPE, java.lang.String NAME, java.lang.String ADDRESS, java.lang.String LOCATION, java.lang.String POSTCODE, java.lang.String COUNTRY, java.lang.String URI, java.lang.Integer BELONGSTO, java.lang.String HOMEPAGE){ Tuple_ORGANIZATIONS r = new Tuple_ORGANIZATIONS(ORGID, TYPE, NAME, ADDRESS, LOCATION, POSTCODE, COUNTRY, URI, BELONGSTO, HOMEPAGE); AddTupleA_ORGANIZATIONS(r); } public static void createTempTableORGANIZATIONS(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_ORGANIZATIONS;\n" + "CREATE TEMP TABLE A_ORGANIZATIONS\n" + "(LIKE ORGANIZATIONS INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static String GenerateURI_CCA2(Tuple_PAPERS rnew) { String uri = removeBlankCaractere(""); uri = uri.replaceAll("\\s+",""); return uri; } public static class Tuple_PAPERS { public Tuple_PAPERS(java.lang.Integer PAPERID,java.lang.String TITLE,java.lang.String ABSTRACT,java.lang.String URI,java.lang.Integer YEAR,java.lang.Integer CONFERENCE,java.lang.Integer PUBLISH) { this.PAPERID = PAPERID; this.TITLE = TITLE; this.ABSTRACT = ABSTRACT; this.URI = URI; this.YEAR = YEAR; this.CONFERENCE = CONFERENCE; this.PUBLISH = PUBLISH; } public Tuple_PAPERS( ){ } public java.lang.Integer PAPERID; public java.lang.String TITLE; public java.lang.String ABSTRACT; public java.lang.String URI; public java.lang.Integer YEAR; public java.lang.Integer CONFERENCE; public java.lang.Integer PUBLISH; } public static Tuple_PAPERS[] obterTuplesPAPERS(ResultSet rs, int rowCount){ Tuple_PAPERS[] listaPAPERS = null; try { listaPAPERS = new Tuple_PAPERS[rowCount]; Tuple_PAPERS tuple = null; int i = 0; while(rs.next()) { tuple = new Tuple_PAPERS(); tuple.PAPERID = (rs.getObject("PAPERID") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("PAPERID"))) : null;tuple.TITLE = (rs.getObject("TITLE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("TITLE"))) : null;tuple.ABSTRACT = (rs.getObject("ABSTRACT") != null) ? new java.lang.String((java.lang.String)(rs.getObject("ABSTRACT"))) : null;tuple.URI = (rs.getObject("URI") != null) ? new java.lang.String((java.lang.String)(rs.getObject("URI"))) : null;tuple.YEAR = (rs.getObject("YEAR") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("YEAR"))) : null;tuple.CONFERENCE = (rs.getObject("CONFERENCE") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("CONFERENCE"))) : null;tuple.PUBLISH = (rs.getObject("PUBLISH") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("PUBLISH"))) : null; listaPAPERS[i] = tuple; i++;} } catch (SQLException e){ }return listaPAPERS; }public static Tuple_PAPERS[] ObtainTuples_PAPERS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PAPERS[] listaPAPERS = null; String sqlConsulta = "SELECT * FROM PAPERS"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPAPERS = obterTuplesPAPERS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } for(Tuple_PAPERS tuple: listaPAPERS){ RDF_State_PAPERS(tuple); } return listaPAPERS; } public static Tuple_PAPERS[] ObtainTuplesA_PAPERS() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PAPERS[] listaPAPERS = null; String sqlConsulta = "SELECT PAPERS.* FROM A_PAPERS, PAPERS WHERE A_PAPERS.PAPERID = PAPERS.PAPERID "; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPAPERS = obterTuplesPAPERS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaPAPERS; } public static void AddTupleA_PAPERS(Tuple_PAPERS t){ String sqlConsulta = ""; sqlConsulta = "INSERT INTO A_PAPERS(PAPERID, TITLE, ABSTRACT, URI, YEAR, CONFERENCE, PUBLISH) VALUES (?, ?, ?, ?, ?, ?, ?)";try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); pstmt.setObject(1, t.PAPERID, 4); pstmt.setObject(2, t.TITLE, 12); pstmt.setObject(3, t.ABSTRACT, 12); pstmt.setObject(4, t.URI, 12); pstmt.setObject(5, t.YEAR, 4); pstmt.setObject(6, t.CONFERENCE, 4); pstmt.setObject(7, t.PUBLISH, 5); pstmt.executeUpdate(); } catch (SQLException e) { } } public static void ObtainAffectedTuples_PAPERS(java.lang.Integer PAPERID, java.lang.String TITLE, java.lang.String ABSTRACT, java.lang.String URI, java.lang.Integer YEAR, java.lang.Integer CONFERENCE, java.lang.Integer PUBLISH){ Tuple_PAPERS r = new Tuple_PAPERS(PAPERID, TITLE, ABSTRACT, URI, YEAR, CONFERENCE, PUBLISH); AddTupleA_PAPERS(r); try { Tuple_CONFERENCES[] Q1 = null; Q1 = ObtainReferencedTuples_papers_ibfk_1(r); if (Q1 != null) { for (Tuple_CONFERENCES t : Q1) { AddTupleA_CONFERENCES(t); } } } catch (SQLException e) {} } public static void createTempTablePAPERS(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_PAPERS;\n" + "CREATE TEMP TABLE A_PAPERS\n" + "(LIKE PAPERS INCLUDING DEFAULTS );\n"; sqlConsulta += "DROP TABLE IF EXISTS A_CONFERENCES;\n" + "CREATE TEMP TABLE A_CONFERENCES\n" + "(LIKE CONFERENCES INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static String GenerateURI_CCA5(Tuple_CONFERENCES rnew) { String uri = removeBlankCaractere(""); uri = uri.replaceAll("\\s+",""); return uri; } public static class Tuple_CONFERENCES { public Tuple_CONFERENCES(java.lang.Integer CONFID,java.lang.String NAME,java.lang.String URI,java.lang.String DATE,java.lang.String LOCATION,java.sql.Timestamp DATUM) { this.CONFID = CONFID; this.NAME = NAME; this.URI = URI; this.DATE = DATE; this.LOCATION = LOCATION; this.DATUM = DATUM; } public Tuple_CONFERENCES( ){ } public java.lang.Integer CONFID; public java.lang.String NAME; public java.lang.String URI; public java.lang.String DATE; public java.lang.String LOCATION; public java.sql.Timestamp DATUM; } public static Tuple_CONFERENCES[] obterTuplesCONFERENCES(ResultSet rs, int rowCount){ Tuple_CONFERENCES[] listaCONFERENCES = null; try { listaCONFERENCES = new Tuple_CONFERENCES[rowCount]; Tuple_CONFERENCES tuple = null; int i = 0; while(rs.next()) { tuple = new Tuple_CONFERENCES(); tuple.CONFID = (rs.getObject("CONFID") != null) ? new java.lang.Integer((java.lang.Integer)(rs.getObject("CONFID"))) : null;tuple.NAME = (rs.getObject("NAME") != null) ? new java.lang.String((java.lang.String)(rs.getObject("NAME"))) : null;tuple.URI = (rs.getObject("URI") != null) ? new java.lang.String((java.lang.String)(rs.getObject("URI"))) : null;tuple.DATE = (rs.getObject("DATE") != null) ? new java.lang.String((java.lang.String)(rs.getObject("DATE"))) : null;tuple.LOCATION = (rs.getObject("LOCATION") != null) ? new java.lang.String((java.lang.String)(rs.getObject("LOCATION"))) : null;tuple.DATUM = (rs.getObject("DATUM") != null) ? (rs.getTimestamp("DATUM")) : null; listaCONFERENCES[i] = tuple; i++;} } catch (SQLException e){ }return listaCONFERENCES; }public static Tuple_CONFERENCES[] ObtainTuples_CONFERENCES() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_CONFERENCES[] listaCONFERENCES = null; String sqlConsulta = "SELECT * FROM CONFERENCES"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaCONFERENCES = obterTuplesCONFERENCES(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } for(Tuple_CONFERENCES tuple: listaCONFERENCES){ RDF_State_CONFERENCES(tuple); } return listaCONFERENCES; } public static Tuple_CONFERENCES[] ObtainTuplesA_CONFERENCES() throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_CONFERENCES[] listaCONFERENCES = null; String sqlConsulta = "SELECT CONFERENCES.* FROM A_CONFERENCES, CONFERENCES WHERE A_CONFERENCES.CONFID = CONFERENCES.CONFID "; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaCONFERENCES = obterTuplesCONFERENCES(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaCONFERENCES; } public static void AddTupleA_CONFERENCES(Tuple_CONFERENCES t){ String sqlConsulta = ""; sqlConsulta = "INSERT INTO A_CONFERENCES(CONFID, NAME, URI, DATE, LOCATION, DATUM) VALUES (?, ?, ?, ?, ?, ?)";try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); pstmt.setObject(1, t.CONFID, 4); pstmt.setObject(2, t.NAME, 12); pstmt.setObject(3, t.URI, 12); pstmt.setObject(4, t.DATE, 12); pstmt.setObject(5, t.LOCATION, 12); pstmt.setObject(6, t.DATUM, 93); pstmt.executeUpdate(); } catch (SQLException e) { } } public static void ObtainAffectedTuples_CONFERENCES(java.lang.Integer CONFID, java.lang.String NAME, java.lang.String URI, java.lang.String DATE, java.lang.String LOCATION, java.sql.Timestamp DATUM){ Tuple_CONFERENCES r = new Tuple_CONFERENCES(CONFID, NAME, URI, DATE, LOCATION, DATUM); AddTupleA_CONFERENCES(r); } public static void createTempTableCONFERENCES(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_CONFERENCES;\n" + "CREATE TEMP TABLE A_CONFERENCES\n" + "(LIKE CONFERENCES INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static class Tuple_REL_PERSON_PAPER { public Tuple_REL_PERSON_PAPER(java.lang.Integer PERSONID,java.lang.Integer PAPERID) { this.PERSONID = PERSONID; this.PAPERID = PAPERID; } public Tuple_REL_PERSON_PAPER( ){ } public java.lang.Integer PERSONID; public java.lang.Integer PAPERID; } public static void ObtainAffectedTuples_REL_PERSON_PAPER(java.lang.Integer PERSONID, java.lang.Integer PAPERID){ Tuple_REL_PERSON_PAPER r = new Tuple_REL_PERSON_PAPER(PERSONID, PAPERID); try { Tuple_PERSONS[] Q1 = null; Q1 = ObtainReferencedTuples_rel_person_paper_ibfk_1(r); if (Q1 != null) { for (Tuple_PERSONS t : Q1) { AddTupleA_PERSONS(t); } } } catch (SQLException e) {} } public static void createTempTableREL_PERSON_PAPER(){ String sqlConsulta = ""; sqlConsulta += "DROP TABLE IF EXISTS A_PERSONS;\n" + "CREATE TEMP TABLE A_PERSONS\n" + "(LIKE PERSONS INCLUDING DEFAULTS );\n"; try { // create temp table conn.createStatement().execute(sqlConsulta); } catch (SQLException e) {} } public static String RDF_State_PERSONS(Tuple_PERSONS rnew){ String S = null,S1,U=""; Object V,O; U = U + "\n"; S = GenerateURI_CCA1(rnew); U = U + GenerateTriple(S," ",""); if (nonNull(rnew.FIRSTNAME)){ V = GenerateTypedLiteral(rnew.FIRSTNAME,"FIRSTNAME","Persons"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.EMAIL)){ V = GenerateTypedLiteral(rnew.EMAIL,"EMAIL","Persons"); U = U + GenerateTriple(S,"",V + "^^"); } try { S = GenerateURI_CCA1 (rnew); Tuple_ORGANIZATIONS [] Q2 = null; Q2 = ObtainReferencedTuples_rel_person_organization_ibfk_1_rel_person_organization_ibfk_2(rnew); if(Q2 != null) { for(int i=0;i",O); } } } catch (SQLException e) { } try { S = GenerateURI_CCA1 (rnew); Tuple_TOPICS [] Q2 = null; Q2 = ObtainReferencedTuples_rel_person_paper_ibfk_1_rel_person_paper_ibfk_2_rel_paper_topic_ibfk_1_rel_paper_topic_ibfk_2(rnew); if(Q2 != null) { for(int i=0;i",O); } } } catch (SQLException e) { } return U; } public static String RDF_State_CONFERENCES(Tuple_CONFERENCES rnew){ String S = null,S1,U=""; Object V,O; U = U + "\n"; S = GenerateURI_CCA5(rnew); U = U + GenerateTriple(S," ",""); if (nonNull(rnew.NAME)){ V = GenerateTypedLiteral(rnew.NAME,"NAME","Conferences"); U = U + GenerateTriple(S,"",V + "^^"); } return U; } public static String RDF_State_TOPICS(Tuple_TOPICS rnew){ String S = null,S1,U=""; Object V,O; U = U + "\n"; S = GenerateURI_CCA6(rnew); U = U + GenerateTriple(S," ",""); if (nonNull(rnew.TOPICNAME)){ V = GenerateTypedLiteral(rnew.TOPICNAME,"TOPICNAME","Topics"); U = U + GenerateTriple(S,"",V + "^^"); } try{ Tuple_TOPICS [] Q; Q = ObtainReferencedTuples_topics_ibfk_1(rnew); if(Q != null) { for(int i=0;i", O); }} } catch (SQLException e) { } return U; } public static String RDF_State_ORGANIZATIONS(Tuple_ORGANIZATIONS rnew){ String S = null,S1,U=""; Object V,O; U = U + "\n"; S = GenerateURI_CCA3(rnew); U = U + GenerateTriple(S," ",""); if (nonNull(rnew.ADDRESS)){ V = GenerateTypedLiteral(rnew.ADDRESS,"ADDRESS","Organizations"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.LOCATION)){ V = GenerateTypedLiteral(rnew.LOCATION,"LOCATION","Organizations"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.POSTCODE)){ V = GenerateTypedLiteral(rnew.POSTCODE,"POSTCODE","Organizations"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.COUNTRY)){ V = GenerateTypedLiteral(rnew.COUNTRY,"COUNTRY","Organizations"); U = U + GenerateTriple(S,"",V + "^^"); } U = U + "\n"; S = GenerateURI_CCA4(rnew); U = U + GenerateTriple(S," ",""); if (nonNull(rnew.NAME)){ V = GenerateTypedLiteral(rnew.NAME,"NAME","Organizations"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.HOMEPAGE)){ V = GenerateTypedLiteral(rnew.HOMEPAGE,"HOMEPAGE","Organizations"); U = U + GenerateTriple(S,"",V + "^^"); } String S2= ""; S2 = GenerateURI_CCA3(rnew); U = U + GenerateTriple(S," ", S2); return U; } public static String RDF_State_PAPERS(Tuple_PAPERS rnew){ String S = null,S1,U=""; Object V,O; U = U + "\n"; S = GenerateURI_CCA2(rnew); U = U + GenerateTriple(S," ",""); if (nonNull(rnew.TITLE)){ V = GenerateTypedLiteral(rnew.TITLE,"TITLE","Papers"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.ABSTRACT)){ V = GenerateTypedLiteral(rnew.ABSTRACT,"ABSTRACT","Papers"); U = U + GenerateTriple(S,"",V + "^^"); } if (nonNull(rnew.YEAR)){ V = GenerateTypedLiteral(rnew.YEAR,"YEAR","Papers"); U = U + GenerateTriple(S,"",V + "^^"); } try { S = GenerateURI_CCA2 (rnew); Tuple_TOPICS [] Q2 = null; Q2 = ObtainReferencedTuples_rel_paper_topic_ibfk_1_rel_paper_topic_ibfk_2(rnew); if(Q2 != null) { for(int i=0;i",O); } } } catch (SQLException e) { } try{ Tuple_CONFERENCES [] Q; Q = ObtainReferencedTuples_papers_ibfk_1(rnew); if(Q != null) { for(int i=0;i", O); }} } catch (SQLException e) { } return U; } public static String RDF_State_REL_PERSON_ORGANIZATION(){ String S = null,S1,U=""; Object V,O; try { Tuple_PERSONS [] listaPERSONS= ObtainTuplesA_PERSONS(); for (Tuple_PERSONS t : listaPERSONS) { U = U + RDF_State_PERSONS(t); } } catch (SQLException e) { } return U; } public static String RDF_State_PERSONS(){ String S = null,S1,U=""; Object V,O; try { Tuple_PERSONS [] listaPERSONS= ObtainTuplesA_PERSONS(); for (Tuple_PERSONS t : listaPERSONS) { U = U + RDF_State_PERSONS(t); } } catch (SQLException e) { } return U; } public static String RDF_State_REL_PERSON_PAPER(){ String S = null,S1,U=""; Object V,O; try { Tuple_PERSONS [] listaPERSONS= ObtainTuplesA_PERSONS(); for (Tuple_PERSONS t : listaPERSONS) { U = U + RDF_State_PERSONS(t); } } catch (SQLException e) { } return U; } public static String RDF_State_CONFERENCES(){ String S = null,S1,U=""; Object V,O; try { Tuple_CONFERENCES [] listaCONFERENCES= ObtainTuplesA_CONFERENCES(); for (Tuple_CONFERENCES t : listaCONFERENCES) { U = U + RDF_State_CONFERENCES(t); } } catch (SQLException e) { } return U; } public static String RDF_State_REL_PAPER_TOPIC(){ String S = null,S1,U=""; Object V,O; try { Tuple_PERSONS [] listaPERSONS= ObtainTuplesA_PERSONS(); for (Tuple_PERSONS t : listaPERSONS) { U = U + RDF_State_PERSONS(t); } } catch (SQLException e) { }try { Tuple_PAPERS [] listaPAPERS= ObtainTuplesA_PAPERS(); for (Tuple_PAPERS t : listaPAPERS) { U = U + RDF_State_PAPERS(t); } } catch (SQLException e) { } return U; } public static String RDF_State_TOPICS(){ String S = null,S1,U=""; Object V,O; try { Tuple_TOPICS [] listaTOPICS= ObtainTuplesA_TOPICS(); for (Tuple_TOPICS t : listaTOPICS) { U = U + RDF_State_TOPICS(t); } } catch (SQLException e) { } return U; } public static String RDF_State_ORGANIZATIONS(){ String S = null,S1,U=""; Object V,O; try { Tuple_ORGANIZATIONS [] listaORGANIZATIONS= ObtainTuplesA_ORGANIZATIONS(); for (Tuple_ORGANIZATIONS t : listaORGANIZATIONS) { U = U + RDF_State_ORGANIZATIONS(t); } } catch (SQLException e) { } return U; } public static String RDF_State_PAPERS(){ String S = null,S1,U=""; Object V,O; try { Tuple_PAPERS [] listaPAPERS= ObtainTuplesA_PAPERS(); for (Tuple_PAPERS t : listaPAPERS) { U = U + RDF_State_PAPERS(t); } } catch (SQLException e) { } return U; } public static Tuple_PERSONS[] ObtainReferencedTuples_rel_person_organization_ibfk_1(Tuple_REL_PERSON_ORGANIZATION rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PERSONS[] listaPERSONS = null; String sqlConsulta = "SELECT per.* FROM PERSONS per WHERE "+rnew.PERSONID+" = per.PERID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPERSONS = obterTuplesPERSONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaPERSONS; } public static Tuple_ORGANIZATIONS[] ObtainReferencedTuples_rel_person_organization_ibfk_1_rel_person_organization_ibfk_2(Tuple_PERSONS rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_ORGANIZATIONS[] listaORGANIZATIONS = null; String sqlConsulta = "SELECT org.* FROM REL_PERSON_ORGANIZATION rpo,ORGANIZATIONS org WHERE "+rnew.PERID+" = rpo.PERSONID"+ " AND rpo.ORGANIZATIONID = org.ORGID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaORGANIZATIONS = obterTuplesORGANIZATIONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaORGANIZATIONS; } public static Tuple_TOPICS[] ObtainReferencedTuples_topics_ibfk_1(Tuple_TOPICS rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_TOPICS[] listaTOPICS = null; String sqlConsulta = "SELECT top.* FROM TOPICS top WHERE "+rnew.PARENTID+" = top.TOPICID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaTOPICS = obterTuplesTOPICS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaTOPICS; } public static Tuple_PERSONS[] ObtainReferencedTuples_rel_paper_topic_ibfk_1_rel_person_paper_ibfk_2_rel_person_paper_ibfk_1(Tuple_REL_PAPER_TOPIC rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PERSONS[] listaPERSONS = null; String sqlConsulta = "SELECT per.* FROM PAPERS pap,REL_PERSON_PAPER rpp,PERSONS per WHERE "+rnew.PAPERID+" = pap.PAPERID"+ " AND pap.PAPERID = rpp.PAPERID"+ " AND rpp.PERSONID = per.PERID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPERSONS = obterTuplesPERSONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaPERSONS; } public static Tuple_TOPICS[] ObtainReferencedTuples_rel_person_paper_ibfk_1_rel_person_paper_ibfk_2_rel_paper_topic_ibfk_1_rel_paper_topic_ibfk_2(Tuple_PERSONS rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_TOPICS[] listaTOPICS = null; String sqlConsulta = "SELECT top.* FROM REL_PERSON_PAPER rpp,PAPERS pap,REL_PAPER_TOPIC rpt,TOPICS top WHERE "+rnew.PERID+" = rpp.PERSONID"+ " AND rpp.PAPERID = pap.PAPERID"+ " AND pap.PAPERID = rpt.PAPERID"+ " AND rpt.TOPICID = top.TOPICID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaTOPICS = obterTuplesTOPICS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaTOPICS; } public static Tuple_PAPERS[] ObtainReferencedTuples_rel_paper_topic_ibfk_1(Tuple_REL_PAPER_TOPIC rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PAPERS[] listaPAPERS = null; String sqlConsulta = "SELECT pap.* FROM PAPERS pap WHERE "+rnew.PAPERID+" = pap.PAPERID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPAPERS = obterTuplesPAPERS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaPAPERS; } public static Tuple_TOPICS[] ObtainReferencedTuples_rel_paper_topic_ibfk_1_rel_paper_topic_ibfk_2(Tuple_PAPERS rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_TOPICS[] listaTOPICS = null; String sqlConsulta = "SELECT top.* FROM REL_PAPER_TOPIC rpt,TOPICS top WHERE "+rnew.PAPERID+" = rpt.PAPERID"+ " AND rpt.TOPICID = top.TOPICID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaTOPICS = obterTuplesTOPICS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaTOPICS; } public static Tuple_CONFERENCES[] ObtainReferencedTuples_papers_ibfk_1(Tuple_PAPERS rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_CONFERENCES[] listaCONFERENCES = null; String sqlConsulta = "SELECT con.* FROM CONFERENCES con WHERE "+rnew.CONFERENCE+" = con.CONFID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaCONFERENCES = obterTuplesCONFERENCES(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaCONFERENCES; } public static Tuple_PERSONS[] ObtainReferencedTuples_rel_person_paper_ibfk_1(Tuple_REL_PERSON_PAPER rnew) throws SQLException{ Connection conn = ConnectionFactory.getConnection(); // conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); Tuple_PERSONS[] listaPERSONS = null; String sqlConsulta = "SELECT per.* FROM PERSONS per WHERE "+rnew.PERSONID+" = per.PERID"; ResultSet result; ResultSet resultCount; int rowcount = 0; try { PreparedStatement pstmt = conn.prepareStatement(sqlConsulta); PreparedStatement pstmt2 = conn.prepareStatement(sqlConsulta); result = pstmt.executeQuery(); resultCount = pstmt2.executeQuery(); while(resultCount.next()){ rowcount++; } listaPERSONS = obterTuplesPERSONS(result,rowcount); pstmt.close(); conn.commit(); } catch (SQLException e) { } return listaPERSONS; } }