package com.ximple.eofms.jobs;
|
|
import java.sql.DriverManager;
|
import java.sql.SQLException;
|
import java.util.Properties;
|
|
import oracle.jdbc.OracleConnection;
|
|
public abstract class AbstractOracleJobContext
|
{
|
private static final String ORACLE_URL = "jdbc:oracle:thin:@";
|
private static final String PROPUsrKey = "user";
|
private static final String PROPPassKey = "password";
|
/**
|
* Table Prefiex
|
*/
|
protected static final String TABLE_PREFIX = "GEO$";
|
protected static final String UDT_SCHEMA = "SPATIALDB";
|
/**
|
* User Types
|
*/
|
protected static final String UDT_RAWS = "CREATE OR REPLACE TYPE \"" + UDT_SCHEMA + "\".\"RAWS\" AS VARRAY (1048576) OF NUMBER(38)";
|
protected static final String UDT_OFMID = "CREATE OR REPLACE TYPE \"" + UDT_SCHEMA + "\".\"OFMID\" AS OBJECT ("
|
+ "\"CLSID\" NUMBER(5), \"OID\" NUMBER(10), \"STATUS\" NUMBER(5), \"COMPID\" NUMBER(3), "
|
+ "\"RULEID\" NUMBER(3), \"OCCID\" NUMBER(3))";
|
protected static final String UDT_RAWSNAME = "RAWS";
|
protected static final String UDT_OFMIDNAME = "OFMID";
|
/**
|
* Utility SQL
|
*/
|
protected static final String TAB_DROP = "DROP TABLE %s.%s CASCADE CONSTRAINTS";
|
protected static final String TAB_DELETE = "DELETE FROM %s.%s";
|
/**
|
* Table Schema
|
*/
|
protected static final String TAB_RANGENODEINDEX_1 = "CREATE TABLE \"%s\".\"%s\"\n"
|
+ " ( \"RNID\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"RPID\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"RNG_LOWX\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"RNG_LOWY\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"RNG_HIGHX\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"RNG_HIGHY\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"EXTENTS\" MDSYS.SDO_GEOMETRY,\n"
|
+ " \"RNDESCR\" VARCHAR2(255), \n"
|
+ " PRIMARY KEY ( \"RNID\" ) ENABLE )";
|
protected static final String TAB_RANGENODEINDEX = "CREATE TABLE \"%s\".\"%s\"\n"
|
+ " ( \"RNID\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"RPID\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"RNG_LOWX\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"RNG_LOWY\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"RNG_HIGHX\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"RNG_HIGHY\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"RNDESCR\" VARCHAR2(255), \n"
|
+ " PRIMARY KEY ( \"RNID\" ) ENABLE )";
|
protected static final String TAB_RANGENODESTORAGE = "CREATE TABLE \"%s\".\"%s\"\n"
|
+ " ( \"RNID\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"LAYERID\" NUMBER(5,0) NOT NULL ENABLE,\n"
|
+ " \"LASTUPDATE\" DATE NOT NULL ENABLE,\n"
|
+ " \"SPACETABLE\" VARCHAR2(255)\n" + " )";
|
protected static final String TAB_ELEMENTINDEX_1 = "CREATE TABLE %s.%s (\n"
|
+ " \"ELMNO\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"TYPE\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"XLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"YLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"ZLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"XHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"YHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"ZHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n"
|
+ " \"TAG_LUFID\" NUMBER(10) NOT NULL ENABLE,\n"
|
+ " \"TAG_SFSC\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"TAG_SSTAT\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"TAG_BCOMPID\" NUMBER(3) NOT NULL ENABLE,\n"
|
+ " \"TAG_BRULENO\" NUMBER(3) NOT NULL ENABLE,\n"
|
+ " \"TAG_SOCCID\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"SPACENAME\" VARCHAR2(255) NOT NULL ENABLE,\n"
|
+ " PRIMARY KEY (\"ELMNO\") ENABLE\n"
|
+ " )";
|
protected static final String TAB_ELEMENTINDEX = "CREATE TABLE %s.%s (\n"
|
+ " \"ELMNO\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"TYPE\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"XLOW\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"YLOW\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"ZLOW\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"XHIGH\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"YHIGH\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"ZHIGH\" FLOAT NOT NULL ENABLE,\n"
|
+ " \"TAG_LUFID\" NUMBER(10) NOT NULL ENABLE,\n"
|
+ " \"TAG_SFSC\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"TAG_SSTAT\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"TAG_BCOMPID\" NUMBER(3) NOT NULL ENABLE,\n"
|
+ " \"TAG_BRULENO\" NUMBER(3) NOT NULL ENABLE,\n"
|
+ " \"TAG_SOCCID\" NUMBER(5) NOT NULL ENABLE,\n"
|
+ " \"SPACENAME\" VARCHAR2(255) NOT NULL ENABLE,\n"
|
+ " PRIMARY KEY (\"ELMNO\") ENABLE\n"
|
+ " )";
|
protected static final String TAB_IGDSSEED = "CREATE TABLE %s.%s (\n"
|
+ " \"ELMNO\" INTEGER NOT NULL ENABLE,\n"
|
+ " \"SEEDELM\" \"" + UDT_SCHEMA
|
+ "\".\"RAWS\" NOT NULL ENABLE\n" + " )";
|
protected static final String TAB_STORAGE_1 = "CREATE TABLE %s.%s (\n" +
|
" \"ELMNO\" INTEGER NOT NULL ENABLE,\n" +
|
" \"XLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"YLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"XHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"YHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"EXTENTS\" MDSYS.SDO_GEOMETRY, \n" +
|
" \"PROPS\" INTEGER NOT NULL ENABLE,\n" +
|
" \"TAG_LUFID\" NUMBER(10) NOT NULL ENABLE,\n" +
|
" \"TAG_SFSC\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"TAG_SSTAT\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"TAG_BCOMPID\" NUMBER(3) NOT NULL ENABLE,\n" +
|
" \"TAG_BRULENO\" NUMBER(3) NOT NULL ENABLE,\n" +
|
" \"TAG_SOCCID\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"LAYERID\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"ELEMENT\" \"" + UDT_SCHEMA + "\".\"RAWS\" NOT NULL ENABLE, \n" +
|
" \"GEOM\" MDSYS.SDO_GEOMETRY \n" +
|
" )";
|
protected static final String TAB_STORAGE = "CREATE TABLE %s.%s (\n" +
|
" \"ELMNO\" INTEGER NOT NULL ENABLE,\n" +
|
" \"XLOW\" FLOAT NOT NULL ENABLE,\n" +
|
" \"YLOW\" FLOAT NOT NULL ENABLE,\n" +
|
" \"XHIGH\" FLOAT NOT NULL ENABLE,\n" +
|
" \"YHIGH\" FLOAT NOT NULL ENABLE,\n" +
|
" \"PROPS\" INTEGER NOT NULL ENABLE,\n" +
|
" \"TAG_LUFID\" NUMBER(10) NOT NULL ENABLE,\n" +
|
" \"TAG_SFSC\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"TAG_SSTAT\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"TAG_BCOMPID\" NUMBER(3) NOT NULL ENABLE,\n" +
|
" \"TAG_BRULENO\" NUMBER(3) NOT NULL ENABLE,\n" +
|
" \"TAG_SOCCID\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"LAYERID\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"ELEMENT\" \"" + UDT_SCHEMA + "\".\"RAWS\" NOT NULL ENABLE \n" +
|
" )";
|
protected static final String TAB_STORAGE2 = "CREATE TABLE %s.%s (\n" +
|
" \"ELMNO\" INTEGER NOT NULL ENABLE,\n" +
|
" \"XLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"YLOW\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"XHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"YHIGH\" BINARY_DOUBLE NOT NULL ENABLE,\n" +
|
" \"EXTENTS\" MDSYS.SDO_GEOMETRY, \n" +
|
" \"PROPS\" INTEGER NOT NULL ENABLE,\n" +
|
" \"ID\" " + UDT_SCHEMA + ".OFMID NOT NULL ENABLE,\n" +
|
" \"LAYERID\" NUMBER(5) NOT NULL ENABLE,\n" +
|
" \"ELEMENT\" \"" + UDT_SCHEMA + "\".\"RAWS\" NOT NULL ENABLE \n" +
|
" )";
|
/**
|
* Trigger
|
*/
|
protected static final String TRG_SPACENODE = "CREATE OR REPLACE TRIGGER \"%s\".\"%s\"\n"
|
+ " AFTER DELETE OR INSERT OR UPDATE ON \"%s\".\"%s\"\n" + " BEGIN\n"
|
+ " UPDATE SPACENODES SET LASTUPDATE = SYSDATE\n" + " WHERE SNID = \"%d\";\n"
|
+ " END;";
|
protected static final String TRG_ELMINDEX =
|
"CREATE OR REPLACE TRIGGER \"%s\".\"%s\"\n"
|
+ " AFTER INSERT OR UPDATE OR DELETE ON \"%s\".\"%s\"\n"
|
+ " REFERENCING OLD AS OLD NEW AS NEW FOR EACH ROW\n"
|
+ " BEGIN\n"
|
+ " IF INSERTING THEN\n"
|
+ " INSERT INTO \"%s\".\"%s\" (ELMNO, TYPE, XLOW, YLOW, XHIGH, YHIGH,\n"
|
+ " UFID, FSC, COMPID, OCCID, SPACENAME)\n"
|
+ " VALUES (SD$ELEMENTNUMBER_SEQ.NEXTVAL, :new.ELMTYPE, :new.XLOW, :new.YLOW, :new.XHIGH, :new.YHIGH,\n"
|
+ " :new.UFID, :new.FSC, :new.COMPID, :new.OCCID, '%s');\n"
|
+ " ELSIF DELETING THEN\n"
|
+ " DELETE FROM \"%s\".\"%s\"\n"
|
+ " WHERE \"%s\".UFID = :old.UFID AND\n"
|
+ " \"%s\".FSC = :old.FSC AND\n"
|
+ " \"%s\".COMPID = :old.COMPID AND\n"
|
+ " \"%s\".OCCID = :old.OCCID;\n"
|
+ " ELSE\n" + " UPDATE \"%s\"\n"
|
+ " SET XLOW = :new.XLOW, YLOW = :new.YLOW, XHIGH = :new.XHIGH, YHIGH = :new.YHIGH\n"
|
+ " WHERE FSC = :new.FSC AND UFID = :new.UFID AND COMPID = :new.COMPID AND OCCID = :new.OCCID;\n"
|
+ " END IF;\n" + " END;";
|
|
/**
|
* copy connectivity to connectivity_webcheck sql
|
*/
|
protected static final String TRUNCATE_CONNECTIVITY_WEBCHECK = "TRUNCATE TABLE BASEDB.CONNECTIVITY_WEBCHECK";
|
protected static final String CREATE_CONNECTIVITY_WEBCHECK = "CREATE TABLE BASEDB.CONNECTIVITY_WEBCHECK\n" +
|
"( FSC NUMBER(5) NOT NULL," +
|
" UFID NUMBER(10) NOT NULL," +
|
" N1 NUMBER(10)," +
|
" N2 NUMBER(10)," +
|
" FDR1 NUMBER(5)," +
|
" FDR2 NUMBER(5)," +
|
" DIR NUMBER(3)," +
|
" OHUG NUMBER(3)," +
|
" OSTATUS NUMBER(3)," +
|
" PHASE NUMBER(3)," +
|
" X NUMBER(10,3) NOT NULL," +
|
" Y NUMBER(10,3) NOT NULL" +
|
")\n" +
|
"TABLESPACE BASE_DATA PCTUSED 40 PCTFREE 10 INITRANS 1 MAXTRANS 255\n" +
|
"STORAGE (INITIAL 19120K MINEXTENTS 1 MAXEXTENTS 2147483645 \n" +
|
"PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT )\n" +
|
"LOGGING NOCOMPRESS NOCACHE NOPARALLEL MONITORING;";
|
|
protected static final String COPY_CONNECTIVITY_TO_WEBCHECK = "INSERT /*+ APPEND */ INTO BASEDB.CONNECTIVITY_WEBCHECK\n" +
|
"(FSC, UFID, N1, N2, FDR1, FDR2, DIR, OHUG,OSTATUS, PHASE, X, Y)\n" +
|
"SELECT FSC, UFID, N1, N2, FDR1, FDR2, DIR, OHUG, OSTATUS, PHASE, X, Y FROM BASEDB.CONNECTIVITY ";
|
|
|
/**
|
*
|
*/
|
protected static final String TAB_ELEMENTSET_PREFIX = "ELMSET_";
|
protected static final String STMT_CLEARCYCLEBIN = "PURGE RECYCLEBIN";
|
protected static final String SMTM_GRANTOBJECTTYPE = "GRANT EXECUTE ANY TYPE TO \"" + UDT_SCHEMA + "\"";
|
protected static final long TIMEOUT = Long.MAX_VALUE;
|
|
/**
|
* Encoding of URL path.
|
*/
|
protected static final String ENCODING = "UTF-8";
|
private String _oracleHost;
|
private String _oracleInstance;
|
private String _oraclePort;
|
protected String _dataPath;
|
private OracleConnection oracleConnection = null;
|
protected Properties properties;
|
protected String _elementLogging = null;
|
|
public static String getCurrentURL(String oracleHost, String oraclePort, String oracleInstance)
|
{
|
StringBuilder builder = new StringBuilder();
|
|
builder.append(ORACLE_URL);
|
builder.append(oracleHost);
|
builder.append(":");
|
builder.append(oraclePort);
|
builder.append(":");
|
builder.append(oracleInstance);
|
|
return builder.toString();
|
}
|
|
public void setLogin(String userName, String password)
|
{
|
properties.put(PROPUsrKey, userName);
|
properties.put(PROPPassKey, password);
|
}
|
|
public void setShapeData(String dataPath)
|
{
|
_dataPath = dataPath;
|
}
|
|
public OracleConnection getOracleConnection()
|
{
|
try
|
{
|
if (oracleConnection == null)
|
{
|
oracleConnection = (OracleConnection) DriverManager.getConnection(
|
getCurrentURL(_oracleHost, _oraclePort, _oracleInstance),
|
properties);
|
}
|
|
return oracleConnection;
|
} catch (SQLException e)
|
{
|
OracleConvertJobContext.logger.warn(e.getMessage(), e);
|
}
|
|
oracleConnection = null;
|
|
return null;
|
}
|
|
public void closeConnection()
|
{
|
try
|
{
|
if (oracleConnection != null)
|
{
|
oracleConnection.close();
|
oracleConnection = null;
|
}
|
} catch (SQLException e)
|
{
|
OracleConvertJobContext.logger.warn(e.getMessage(), e);
|
}
|
}
|
|
public void setConnectionInfo(String oracleHost, String oraclePort, String oracleInstance)
|
{
|
_oracleHost = oracleHost;
|
_oracleInstance = oracleInstance;
|
_oraclePort = oraclePort;
|
}
|
|
public String getDataPath()
|
{
|
return _dataPath;
|
}
|
|
public String getOracleHost()
|
{
|
return _oracleHost;
|
}
|
|
public String getOracleInstance()
|
{
|
return _oracleInstance;
|
}
|
|
public String getOraclePort()
|
{
|
return _oraclePort;
|
}
|
|
public String getElementLogging()
|
{
|
return _elementLogging;
|
}
|
|
public void setElementLogging(String elementLogging)
|
{
|
_elementLogging = elementLogging;
|
}
|
|
public boolean checkElementLogging()
|
{
|
return _elementLogging != null && !_elementLogging.equalsIgnoreCase("false") &&
|
!_elementLogging.equalsIgnoreCase("no") && !_elementLogging.equalsIgnoreCase("0");
|
}
|
|
public abstract void startTransaction();
|
|
public abstract void commitTransaction();
|
|
public abstract void rollbackTransaction();
|
}
|
