package system.rsrserver;
import java.io.*;
import java.sql.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.util.*;
import java.net.*;
import LogPrinter;
/**
* main class of the System Resource Server
* Creation date: (12/27/99 11:11:40 AM)
* @author: lex
*
* requests model
*
*
* ReqType=0
* Returns Overview page
* command string:
* ResourceServer?ReqType=0
* returns:
* html
*
* ReqType=1
* get all active languages
* command string:
* ResourceServer?ReqType=1&marketKey=1
* returns:
* Nx langKey|langShortName|langName
*
*
* ReqType=2
* register a language
* notes:
* the short name must have specific value. the first two letters from this value are used
* for comparation in the http header, when a page is about to be downloaded
* command string:
* ResourceServer?ReqType=2&langName=Greece&langShortName=gre
* returns:
* langKey
*
*
* ReqType=3
* register a market (su)
* command string:
* ResourceServer?ReqType=3&marketName=SU&marketDescr=SU-Sofia
* returns:
* marketKey
*
*
* ReqType=4
* activate a registred market (su)
* command string:
* ResourceServer?ReqType=4&marketKey=2
* returns:
* nothing
*
*
* ReqType=5
* deactivate a language (su)
* command string:
* ResourceServer?ReqType=5&langKey=8
* returns:
* nothing
*
*
* ReqType=6
* deactivate a market (su)
* command string:
* ResourceServer?ReqType=6&marketKey=2
* returns:
* nothing
*
*
* ReqType=7
* get all markets (su)
* command string:
* ResourceServer?ReqType=7
* returns:
* Nx marketKey|marketName|marketDescr|marketStatus
*
* ReqType=8
* return a list of languages with service-html interface (su)
* command string:
* ResourceServer?ReqType=8
* returns:
* html page
*
* ReqType=9
* return lists of markets with service-html interface (su)
* command string:
* ResourceServer?ReqType=9
* returns:
* html page
*
* ReqType=10
* return a list of the valid markets for validation of the other system modules
* command string:
* ResourceServer?ReqType=10
* //here we need more info to make this secure, otherwise everybody could get the list
* returns:
* numOfRecords|marketKey1|marketKey2|ma...
*
* ReqType=11
* return a configuration html page
* command string:
* ResourceServer?ReqType=11
* returns:
* html page
*
* ReqType=12
* Change parameter value.
* command string:
* ResourceServer?ReqType=12&name=MYSQLDriver&value=org.gjt.mm.mysql.Driver
* returns:
* Confuguration html page
*
* ReqType=13
* Saves config parameters into a file.
* command string:
* ResourceServer?ReqType=13
* returns:
* Confuguration html page
*
* ReqType=14
* return a html page. add language page
* command string:
* ResourceServer?ReqType=14
* returns:
* Add lang html page
*
* ReqType=15
* return a html page. Add market page
* command string:
* ResourceServer?ReqType=15
* returns:
* Add marjet html page
*
* ReqType=16
* re - init the servlet
* command string:
* ResourceServer?ReqType=16
* returns:
* nothing
*
*/
public class ResourceServer extends javax.servlet.http.HttpServlet {
private static Connection rsrDBConn;
private static int[] rsrActiveMarkets;
private static LogPrinter LogOutput;
public static ConfigRSRServer rsrConfig;
private int rsrMarketKey;
private static Object rsrDBSync = new Object();
public String ver = "AAA000 | 000712";
/**
* ResourceServer constructor.
*/
public ResourceServer() {
super();
}
/**
* the destroy method of the servlet
* closes the connection to the db using the rsrDBDisConnect() method
* Creation date: (15.2.00 15:01:42)
*/
public void destroy() {
rsrDBDisConnect();
}
/**
* this is the init method of the servlet.
* estaablishe a db connection using rsrDBConnect() method
* Creation date: (15.2.00 15:37:51)
*/
public void init(ServletConfig config) throws ServletException {
super.init(config); //This statement must always be here !!!
rsrInit();
}
/**
* marks a market as active in the db
* Creation date: (2.2.00 23:47:57)
*/
public synchronized boolean rsrActivateMarket(int marketKey) {
String SQLStat;
int marketStatus = -1;
Statement Stmt;
SQLStat = "select " + RSRConstants.sDBFieldMarketStatus + " from " + RSRConstants.sDBMarketsTableName + " where " + RSRConstants.sDBFieldMarketKey + " = " + marketKey;
boolean exit = true;
boolean result;
int error_counter = 0;
do {
try {
Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
if (RS.next())
marketStatus = RS.getInt(1);
else {
LogOutput.log("fail on activating market - no such market", LogOutput.ERROR);
LogOutput.flush();
result = false;
}
RS.close();
Stmt.close();
if (marketStatus == 0) {
// market is not-active, activate it
SQLStat = "update " + RSRConstants.sDBMarketsTableName + " set " + RSRConstants.sDBFieldMarketStatus + " = 1, " + RSRConstants.sDBFieldMarketActivationDate + " = '" + String.valueOf(new java.sql.Date(System.currentTimeMillis())) + "' where " + RSRConstants.sDBFieldMarketKey + " = " + marketKey;
Stmt = rsrDBConn.createStatement();
Stmt.executeQuery(SQLStat);
Stmt.close();
} else
if (marketStatus == 1)
// market is active, do nothing
result = true;
else
// market is deactivated, activation fail
result = false;
exit = true;
result = true;
} catch (SQLException E) {
LogOutput.log("fail on activating market - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
// sql error, activation fail
result = false;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* Builds a list with valid markets (as a String) for the others system-side modules
* Creation date: (22.2.2000 a. 23:31:10)
* @return java.lang.String
*/
private String rsrBuildActiveMarketsList() {
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + " from " + RSRConstants.sDBMarketsTableName + " where " + RSRConstants.sDBFieldMarketStatus + " = 1";
String resString = "";
int counter = 0;
boolean exit = true;
String result;
int error_counter = 0;
do {
try {
Statement Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
counter++;
resString = resString + "|" + RS.getString(1);
}
RS.close();
Stmt.close();
exit = true;
result = counter + resString;
} catch (SQLException E) {
LogOutput.log("fail on building active markets' list - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
result = null;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* Part of the interface part of the servlet.
* generates an interface for languages management.
* generates html.
* Creation date: (20.2.2000 a. 11:43:39)
* @return java.lang.String
*/
private String rsrBuildHTMLLangInterFace() {
String resString;
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangName + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangActive + " = 1";
boolean exit = true;
int error_counter = 0;
resString = "";
resString = resString + "
";
resString = resString + " SELECT A LANGUAGE TO BE DEACTIVATED
";
resString = resString + "
";
resString = resString + "
";
resString = resString + "ENTER VALUES FOR A NEW LANGUAGE
";
resString = resString + "
";
resString = resString + "
";
resString = resString + "";
return resString;
}
/**
* Part of the interface part of the servlet.
* generates an interface for markets management.
* generates html.
* Creation date: (20.2.2000 a. 15:17:58)
* @return java.lang.String
*/
private String rsrBuildHTMLMarketInterFace() {
String resString;
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangName + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangActive + " = 1";
boolean exit = true;
int error_counter = 0;
resString = "";
resString = resString + "
";
resString = resString + " SELECT A LANGUAGE TO BE DEACTIVATED
";
resString = resString + "
";
resString = resString + "
";
resString = resString + "ENTER VALUES FOR A NEW LANGUAGE
";
resString = resString + "
";
resString = resString + "
";
resString = resString + "";
return resString;
}
/**
* Change a config param's
* Creation date: (07.3.2000 a. 16:38:17)
* @param req HttpServletRequest
*/
public void rsrChangeParams(HttpServletRequest req) {
String paramName = "";
String paramValue = "";
try {
paramName = req.getParameter(RSRConstants.sName);
paramValue = req.getParameter(RSRConstants.sValue);
} catch (NumberFormatException e) {
LogOutput.log("bad data type for config parameter name", LogOutput.ERROR);
LogOutput.flush();
return;
}
rsrConfig.setParam(paramName, paramValue);
}
/**
* check if the conection is closed or null
* return true if the connection is ok
* return false if the connection is null or closed
* Creation date: (4/24/00 6:16:46 PM)
* @return boolean
*/
private boolean rsrCheckConnection() {
try {
if (!rsrDBConn.isClosed() && rsrDBConn != null) return true;
else return false;
} catch (Exception E) {
return false;
}
}
/**
* Check if the marketKey form the request is a valid one
* Creation date: (26.2.2000 a. 19:56:10)
* @return boolean
* @param marketKey int
*/
public boolean rsrCheckForActiveMarket(int marketKey) {
if (rsrActiveMarkets == null)
return false;
else
for (int counter = 0; counter < rsrActiveMarkets.length; counter++)
if (rsrActiveMarkets[counter] == marketKey)
return true;
return false;
}
/**
* establishe a connection with the db.
* stores a pointer to the connection in the rsrDBConn field
* Creation date: (12/27/99 1:32:23 PM)
*/
private boolean rsrDBConnect() {
// establish a connection to the db and put a reference to it in the srcDBConn field
// if an exception is generated, retry int countOfTries times
// servlet - wide synchronized by the static field DBInitSync
int countOfTries = 3;
boolean flag = true;
try {
if (rsrDBConn == null || rsrDBConn.isClosed()) {
synchronized (rsrDBSync) {
for (int counter = 0; counter < countOfTries && (rsrDBConn == null || rsrDBConn.isClosed()); counter++) {
try {
rsrDBConn = DriverManager.getConnection(rsrConfig.sDBLocation + rsrConfig.sDBName, rsrConfig.sDBUser, rsrConfig.sDBPass);
LogOutput.log("db connected", LogOutput.INFO);
LogOutput.flush();
flag = true;
} catch (SQLException E) {
LogOutput.log("fail on connecting with the db - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
flag = false;
}
}
}
}
} catch (SQLException E) {
LogOutput.log("fail on connecting with the db - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
flag = false;
}
return flag;
}
/**
* closes the db connection pointed by the rsrDBConn field
* Creation date: (12/27/99 1:32:44 PM)
*/
private void rsrDBDisConnect() {
try {
rsrDBConn.close();
} catch (Exception E) {
LogOutput.log("fail on closing the db connection - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
}
}
/**
* update a language as not active
* Creation date: (3.2.00 11:41:38)
* @param langKey int - the langKey of the language to be disactivated
*/
private synchronized boolean rsrDeActivateLang(int langKey) {
String SQLStat;
Statement Stmt;
SQLStat = "select " + RSRConstants.sDBFieldLangActive + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangKey + " = " + langKey;
boolean exit = true;
boolean result;
int error_counter = 0;
do {
try {
Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
if (RS.next()) {
if (RS.getInt(1) <= 0)
// language is allready active, deactivation ok
result = true;
} else { // no such language, deactivation fail
LogOutput.log("fail on deactivating language - no such language", LogOutput.ERROR);
LogOutput.flush();
result = false;
}
RS.close();
Stmt.close();
SQLStat = "UPDATE " + RSRConstants.sDBLanguagesTableName + " SET " + RSRConstants.sDBFieldLangActive + " = -1 where " + RSRConstants.sDBFieldLangKey + " = " + langKey;
Stmt = rsrDBConn.createStatement();
Stmt.executeQuery(SQLStat);
Stmt.close();
exit = true;
result = true;
} catch (SQLException E) {
LogOutput.log("fail on deactivating language - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
// sql exception, deactivation fails
result = false;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* update marketStatus and marketDeactivationDate fields form markets table
* this "marks" the market as deactivated
* Creation date: (04.2.2000 a. 17:29:38)
* @param marketKey int - the langKey of the market to be disactivated
*/
private synchronized boolean rsrDeActivateMarket(int marketKey) {
String SQLStat;
Statement Stmt;
SQLStat = "select " + RSRConstants.sDBFieldMarketStatus + " from " + RSRConstants.sDBMarketsTableName + " where " + RSRConstants.sDBFieldMarketKey + " = " + marketKey;
boolean exit = true;
boolean result;
int error_counter = 0;
do {
try {
Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
if (RS.next()) {
if (RS.getInt(1) <= 0)
// market allready not active, ok
result = true;
} else {
// no such market
LogOutput.log("fail on deactivating market - no such language", LogOutput.ERROR);
LogOutput.flush();
result = false;
}
RS.close();
Stmt.close();
SQLStat = "UPDATE " + RSRConstants.sDBMarketsTableName + " SET " + RSRConstants.sDBFieldMarketStatus + " = -1, " + RSRConstants.sDBFieldMarketDeactivationDate + " = '" + new java.sql.Date(System.currentTimeMillis()) + "' where " + RSRConstants.sDBFieldMarketKey + " = " + marketKey;
Stmt = rsrDBConn.createStatement();
Stmt.executeQuery(SQLStat);
Stmt.close();
exit = true;
result = true;
} catch (SQLException E) {
LogOutput.log("fail on deactivating market - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
// sql error, deactivation fail
result = false;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* Return Web page to browser.
This page is for adding a new language
* Creation date: (12/16/99 11:31:06 AM)
* @param fileOut java.io.PrintWriter
*/
public void rsrFormAddLang(PrintWriter fileOut) {
String serverName = "ResourceServer?";
int count = 0;
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangName + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangActive + " = 1";
boolean exit = true;
int error_counter = 0;
fileOut.println("");
fileOut.println("");
fileOut.println("LANGUAGE TABLE");
fileOut.println("");
fileOut.println("");
fileOut.println("");
fileOut.println("Language Table
");
fileOut.println("\n");
fileOut.println("\n");
fileOut.println("\n");
fileOut.close();
} // rsrFormLangTabHtml
/**
* Return Web page to browser.
This page is for adding a new market
* Creation date: (03/12/00 11:31:06 AM)
* @param fileOut java.io.PrintWriter
*/
public void rsrFormAddMarket(PrintWriter fileOut) {
String serverName = "ResourceServer?";
int count = 0;
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + ", " + RSRConstants.sDBFieldMarketName + ", " + RSRConstants.sDBFieldMarketDescr + ", " + RSRConstants.sDBFieldMarketStatus + " from " + RSRConstants.sDBMarketsTableName;
boolean exit = true;
int error_counter = 0;
fileOut.println("");
fileOut.println("");
fileOut.println("MARKET TABLE");
fileOut.println("");
fileOut.println("");
fileOut.println("");
fileOut.println("Market Table
");
fileOut.println("\n");
fileOut.println(" \n");
fileOut.println("\n");
fileOut.println("\n");
fileOut.close();
}
/**
* Return Web page to browser.
This is the configuration page of MDVServer
* Creation date: (07/03/00 09:00:26 AM)
* @param fileOut java.io.PrintWriter
*/
public void rsrFormConfigParam(PrintWriter fileOut) {
String serverName = "ResourceServer?";
fileOut.println("");
fileOut.println("");
fileOut.println("Param configurations of ResourceServer");
fileOut.println("");
fileOut.println("");
fileOut.println("");
fileOut.println("Param configurations of ResourceServer
");
fileOut.println("");
fileOut.println("");
fileOut.println("
");
fileOut.println("");
fileOut.println("");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println(" | Resource Server | ");
fileOut.println(" | ");
fileOut.println(" ");
fileOut.println(" | "+rsrConfig.namesMYSQLDriver+" | ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println("\n");
fileOut.println(" ");
fileOut.println(" | "+rsrConfig.namesDBName +" | ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println("\n");
fileOut.println(" ");
fileOut.println(" | "+rsrConfig.namesDBLocation +" | ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println("\n");
fileOut.println(" ");
fileOut.println(" | "+rsrConfig.namesDBUser +" | ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println("\n");
fileOut.println(" ");
fileOut.println(" | "+rsrConfig.namesDBPass +" | ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println("\n");
fileOut.println(" ");
fileOut.println(" | "+rsrConfig.namesLogFilePath +" | ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println(" ");
fileOut.println(" | ");
fileOut.println("
");
fileOut.println("
");
fileOut.println("\n");
fileOut.close();
} // rsrFormConfigPage
/**
* Return Web page to browser.
This page contein Language table , and su-functions(su):
* - Subscribe new language
* - Delete language
* - get Edit language page
* - get Add language page
* Creation date: (12/16/99 11:31:06 AM)
* @param fileOut java.io.PrintWriter
*/
public void rsrFormLangTab(PrintWriter fileOut) {
String serverName = "ResourceServer?";
int count = 0;
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangName + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangActive + " = 1";
boolean exit = true;
int error_counter = 0;
fileOut.println("");
fileOut.println("");
fileOut.println("LANGUAGE TABLE");
fileOut.println("");
fileOut.println("");
fileOut.println("");
fileOut.println("Language Table
");
fileOut.println("\n");
fileOut.println("\n");
fileOut.close();
} // rsrFormLangTabHtml
/**
* Return Web page to browser.
This page conteins Market table , and su-functions(su):
* - Subscribe new market
* - Delete market
* - get Edit market page
* - get Add market page
* Creation date: (13/03/00 11:31:06 AM)
* @param fileOut java.io.PrintWriter
*/
public void rsrFormMarketTab(PrintWriter fileOut) {
String serverName = "ResourceServer?";
int count = 0;
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + ", " + RSRConstants.sDBFieldMarketName + ", " + RSRConstants.sDBFieldMarketDescr + ", " + RSRConstants.sDBFieldMarketStatus + " from " + RSRConstants.sDBMarketsTableName;
boolean exit = true;
int error_counter = 0;
fileOut.println("");
fileOut.println("");
fileOut.println("MARKET TABLE");
fileOut.println("");
fileOut.println("");
fileOut.println("");
fileOut.println("Market Table
");
fileOut.println("\n");
fileOut.println("\n");
fileOut.close();
}
/**
* Return Web page to browser.
This is the Overview page . Contains links to
* Market table
* language table
* Configuration interface
* Re-init
* Creation date: (12/03/00 11:31:06 AM)
* @param fileOut java.io.PrintWriter
*/
public void rsrFormOverview( PrintWriter fileOut ) {
String serverNane="ResourceServer?";
fileOut.println("");
fileOut.println("");
fileOut.println("Resource Server Overview");
fileOut.println("");
fileOut.println("");
fileOut.println("");
// fileOut.println("");
fileOut.println("
Resource Server Overview
");
fileOut.println("ver. " + ver);
fileOut.println("
");
fileOut.println("");
fileOut.println("\n");
fileOut.close();
} // rsrFormOverview
/**
* Builds a list with the active market keys for internal use (needs to request validation)
* Creation date: (27.2.2000 a. 14:57:56)
*/
private boolean rsrGetActiveMarkets() {
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + " from " + RSRConstants.sDBMarketsTableName + " where " + RSRConstants.sDBFieldMarketStatus + " = 1";
Statement Stmt;
ResultSet RS;
int counter = 0;
boolean exit = true;
boolean result;
int error_counter = 0;
do {
try {
// find the number of the active markets
Stmt = rsrDBConn.createStatement();
RS = Stmt.executeQuery(SQLStat);
while (RS.next())
counter++;
RS.close();
Stmt.close();
// get the keys of the active markets
rsrActiveMarkets = new int[counter];
counter = 0;
Stmt = rsrDBConn.createStatement();
RS = Stmt.executeQuery(SQLStat);
while (RS.next())
rsrActiveMarkets[counter++] = RS.getInt(1);
RS.close();
Stmt.close();
// check for errors
if (rsrActiveMarkets.length == 0) {
LogOutput.log("no valid markets", LogOutput.ERROR);
LogOutput.flush();
result = false;
} else
result = true;
exit = true;
} catch (SQLException E) {
LogOutput.log("sql exception on getting the active marktes - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
result = false;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* returns a string containing info about the languages as a string
* Creation date: (12/28/99 12:11:45 PM)
* @param marketKey int - if the param is equal to 1 return all the active languages
* in format langKey|langShortName|langName \n next language
* else return all the languages in format
* langKey|langShortName|langName|langActive \n next language
*/
private String rsrGetLanguages(int Filter) {
int counter = 0;
String resString = "";
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangName + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangActive + " = 1";
boolean exit = true;
int error_counter = 0;
do {
try {
if (Filter == 1) {
int count;
Statement Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
resString = resString + RS.getInt(1) + "|" + RS.getString(2) + "|" + RS.getString(3) + "\n";
}
RS.close();
Stmt.close();
} else {
SQLStat = "select " + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangName + ", " + RSRConstants.sDBFieldLangActive + " from " + RSRConstants.sDBLanguagesTableName;
int count;
Statement Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
resString = resString + RS.getInt(1) + "|" + RS.getString(2) + "|" + RS.getString(3) + "|" + RS.getString(4) + "\n";
}
RS.close();
Stmt.close();
}
exit = true;
} catch (SQLException E) {
LogOutput.log("fail on getting languages - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
error_counter++;
}
} while (!exit && error_counter < 3);
return resString;
}
/**
* returns all the markets in a format string
* Creation date: (3.2.00 1:16:53)
* @return java.lang.String
*/
private String rsrGetMarkets() {
String resString = "";
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + ", " + RSRConstants.sDBFieldMarketName + ", " + RSRConstants.sDBFieldMarketDescr + ", " + RSRConstants.sDBFieldMarketStatus + " from " + RSRConstants.sDBMarketsTableName;
boolean exit = true;
String result;
int error_counter = 0;
do {
try {
int count;
Statement Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
resString = resString + RS.getInt(1) + "|" + RS.getString(2) + "|" + RS.getString(3) + "|" + RS.getString(4) + "\n";
}
RS.close();
Stmt.close();
exit = true;
result = resString;
} catch (SQLException E) {
LogOutput.log("fail on getting markets - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
result = null;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* return a valid value for a new langKey for the resources db.
* it needs an established connection to the db, pointed by the rsrDBConn field.
* the new langKey is calculated by finding the biggest one in the db an incrementing it.
* Creation date: (12/28/99 4:37:56 AM)
* @return int
*/
private synchronized int rsrGetNewLangKey() {
int langKey = 0;
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + " from " + RSRConstants.sDBLanguagesTableName;
boolean exit = true;
int result;
int error_counter = 0;
do {
try {
Statement Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
if (langKey < RS.getInt(1)) {
langKey = RS.getInt(1);
}
}
langKey++;
RS.close();
Stmt.close();
exit = true;
result = langKey;
} catch (SQLException E) {
LogOutput.log("fail on getting new langKey - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
result = 0;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* find a valid key for a new market
* Creation date: (12/28/99 4:21:35 AM)
*/
private synchronized int rsrGetNewMarketKey() {
int marketKey = 0;
boolean exit = true;
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + " from " + RSRConstants.sDBMarketsTableName;
int result;
int error_counter = 0;
do {
try {
Statement Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
if (marketKey < RS.getInt(1)) {
marketKey = RS.getInt(1);
}
}
marketKey++;
RS.close();
Stmt.close();
exit = true;
result = marketKey;
} catch (SQLException E) {
LogOutput.log("fail on getting new marketKey - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
result = 0;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* contains all the init routines for the servlet
* Creation date: (17.3.2000 a. 15:07:13)
*/
private boolean rsrInit() {
rsrConfig = new ConfigRSRServer();
String tempCfgPath = getInitParameter(RSRConstants.sCfgPath);
if (tempCfgPath != null)
rsrConfig.sRSRCfgPath = tempCfgPath;
rsrConfig.cfgLoadProperty(rsrConfig.sRSRCfgPath);
LogOutput = LogPrinter.makeLogPrinter(rsrConfig.sLogFilePath);
LogOutput.setLogLevel(LogPrinter.ALL);
LogOutput.setScreenLogLevel(LogPrinter.ALL);
if (rsrLoadDriver()) {
if (!rsrDBConnect())
return false;
} else
return false;
LogOutput.log("Init Servlet", LogOutput.INFO);
LogOutput.flush();
return true;
}
/**
* Loads the db driver
* it must be executed before trying to establish a connection with the db
* Creation date: (4/25/00 7:53:23 PM)
* @return boolean
*/
private boolean rsrLoadDriver() {
// load the driver
try {
Class.forName(rsrConfig.sMYSQLDriver).newInstance();
return true;
} catch (Exception E) {
LogOutput.log("fail on loading dbDriver " + E, LogOutput.ERROR);
LogOutput.flush();
return false;
}
}
/**
* check if a language exist by langName/langShortName.
* if not, add it in languages table
* Creation date: (12/27/99 11:58:23 AM)
* @return int
*/
private int rsrResolveLang(String langName, String langShortName) {
int langKey = 0;
Statement Stmt;
boolean exit = true;
String SQLStat = "select " + RSRConstants.sDBFieldLangKey + " from " + RSRConstants.sDBLanguagesTableName + " where " + RSRConstants.sDBFieldLangName + " = \"" + langName + "\" and " + RSRConstants.sDBFieldLangShortName + " = \"" + langShortName + "\"";
int result;
int error_counter = 0;
do {
try {
Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
if (RS.next()) {
langKey = RS.getInt(1);
}
RS.close();
Stmt.close();
if (langKey == 0) {
langKey = rsrGetNewLangKey();
SQLStat = "INSERT INTO " + RSRConstants.sDBLanguagesTableName + " (" + RSRConstants.sDBFieldLangKey + ", " + RSRConstants.sDBFieldLangName + ", " + RSRConstants.sDBFieldLangShortName + ", " + RSRConstants.sDBFieldLangActive + ") values (" + langKey + ", \"" + langName + "\", \"" + langShortName + "\", 1)";
Stmt = rsrDBConn.createStatement();
Stmt.executeQuery(SQLStat);
Stmt.close();
}
exit = true;
result = langKey;
} catch (SQLException E) {
LogOutput.log("fail on resolving a language - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
result = 0;
error_counter++;
}
} while (!exit && error_counter < 3);
return result;
}
/**
* check if a market exist by marketName/marketDescr.
* if not, add it in markets table
* Creation date: (12/27/99 11:57:50 AM)
* @return int
*/
private int rsrResolveMarket(String marketName, String marketDescr) {
int marketKey = 0;
Statement Stmt;
boolean exit = true;
String SQLStat = "select " + RSRConstants.sDBFieldMarketKey + " from " + RSRConstants.sDBMarketsTableName + " where " + RSRConstants.sDBFieldMarketName + " = \"" + marketName + "\" and " + RSRConstants.sDBFieldMarketDescr + " = \"" + marketDescr + "\"";
int error_counter = 0;
do {
try {
Stmt = rsrDBConn.createStatement();
ResultSet RS = Stmt.executeQuery(SQLStat);
while (RS.next()) {
marketKey = RS.getInt(1);
}
RS.close();
Stmt.close();
if (marketKey == 0) {
marketKey = rsrGetNewMarketKey();
SQLStat = "INSERT INTO " + RSRConstants.sDBMarketsTableName + " (" + RSRConstants.sDBFieldMarketKey + ", " + "marketName, marketDescr, marketStatus) " + "values (" + String.valueOf(marketKey) + ", \"" + marketName + "\", \"" + marketDescr + "\", 0)";
Stmt = rsrDBConn.createStatement();
Stmt.executeQuery(SQLStat);
Stmt.close();
}
exit = true;
} catch (SQLException E) {
LogOutput.log("fail on resolving a market - sql exception - " + E.getMessage(), LogOutput.ERROR);
LogOutput.flush();
exit = !rsrServeConnection();
error_counter++;
}
} while (!exit && error_counter < 3);
return marketKey;
}
/**
* Saves the cfg file
* Creation date: (07.3.2000 a. 16:38:17)
* @param req HttpServletRequest
*/
public void rsrSaveCfgFile() {
rsrConfig.cfgSaveProperty( rsrConfig.sRSRCfgPath );
}
/**
* checks what is the state of the db connection and restores/establish it if needed
* Creation date: (4/24/00 6:01:24 PM)
* @return boolean
*/
private boolean rsrServeConnection() {
// got to synchronize this
if (!rsrCheckConnection()) {
if (!rsrDBConnect()) {
LogOutput.log("fail on restoring the db-connection", LogOutput.ERROR);
LogOutput.flush();
return false;
} else {
LogOutput.log("db-connection restored", LogOutput.INFO);
LogOutput.flush();
return true;
}
} else {
LogOutput.log("db-connection checked, found active", LogOutput.INFO);
LogOutput.flush();
return true;
}
}
/**
* recieve and proceed all the http requests
* Creation date: (12/27/99 11:12:20 AM)
*/
public void service(HttpServletRequest req, HttpServletResponse res) throws ServletException, java.io.IOException {
int sTask = 0;
boolean result;
int marketKey = -1;
int langKey;
String langName, langShortName, marketName, marketDescr;
PrintWriter out = res.getWriter();
try {
sTask = Integer.valueOf(req.getParameter(RSRConstants.sReqType)).intValue();
} catch (NumberFormatException e) {
out.println("false");
out.close();
LogOutput.log("bad data type for reqType", LogOutput.ERROR);
LogOutput.flush();
return;
}
// check if the request is a valid one
if (sTask < 0 || sTask > 16) {
out.println("false");
out.close();
LogOutput.log("invalid value for reqType", LogOutput.ERROR);
LogOutput.flush();
return;
}
switch (sTask) {
case 0:
// get overview page
rsrFormOverview(out);
break;
case 1 :
// get all active languages for sending them to a market
LogOutput.log("start: get all active languages for sending them to a market", LogOutput.INFO);
try {
marketKey = Integer.valueOf(req.getParameter(RSRConstants.sMarketKey)).intValue();
rsrMarketKey = marketKey; // Kotev polzva rsrMarketKey
} catch (NumberFormatException e) {
out.println("false");
out.close();
LogOutput.log("bad data type for marketKey", LogOutput.ERROR);
LogOutput.flush();
return;
}
if (rsrActiveMarkets == null)
if (!rsrGetActiveMarkets()) {
out.println("false");
out.close();
LogOutput.log("fail on getting the active markets key", LogOutput.ERROR);
LogOutput.flush();
return;
}
if (!rsrCheckForActiveMarket(marketKey)) {
out.println("false");
out.close();
LogOutput.log("request from a not - valid market", LogOutput.ERROR);
LogOutput.flush();
return;
}
String Langs = rsrGetLanguages(1);
out.print(Langs);
LogOutput.log("final: get all active languages for sending them to a market", LogOutput.INFO);
break;
case 2 :
// register language (su)
LogOutput.log("start: register language (su)", LogOutput.INFO);
// read the input - langName / langShortName
try {
langName = req.getParameter(RSRConstants.sLangName);
langShortName = req.getParameter(RSRConstants.sLangShortName);
} catch (Exception e) {
out.println("false");
out.close();
LogOutput.log("bad data type or no data on lang name or langName and langShortName", LogOutput.ERROR);
LogOutput.flush();
return;
}
// check for empty input
if (langName == null || langName.equals("") || langShortName == null || langShortName.equals("")) {
// bad input values, report the error and do nothing
out.println("false");
out.close();
LogOutput.log("bad values of langName or/and langshortName", LogOutput.ERROR);
LogOutput.flush();
return;
}
langKey = rsrResolveLang(langName, langShortName);
rsrFormLangTab( out );
// out.print(langKey);
LogOutput.log("final: register language (su)", LogOutput.INFO);
break;
case 3 :
// register market (su)
LogOutput.log("start: register market (su)", LogOutput.INFO);
// read the input - marketName / marketDescr
try {
marketName = req.getParameter(RSRConstants.sMarketName);
marketDescr = req.getParameter(RSRConstants.sMarketDescr);
} catch (Exception e) {
// bad input, report the error and do nothing
out.println("false");
out.close();
LogOutput.log("bad data type of marketName or/and marketDescr", LogOutput.ERROR);
LogOutput.flush();
return;
}
if (marketName == null || marketName.equals("") || marketDescr == null || marketDescr.equals("")) {
// bad input values, report the error and do nothing
out.println("false");
out.close();
LogOutput.log("bad values of marketName or/and marketDescr", LogOutput.ERROR);
LogOutput.flush();
return;
}
marketKey = rsrResolveMarket(marketName, marketDescr);
// out.print(marketKey);
rsrFormMarketTab( out );
LogOutput.log("final: register market (su)", LogOutput.INFO);
break;
case 4 :
// acrivate market (su)
LogOutput.log("start: acrivate market (su)", LogOutput.INFO);
try {
marketKey = Integer.valueOf(req.getParameter(RSRConstants.sMarketKey)).intValue();
} catch (NumberFormatException e) {
// bad input, report the error and do nothing
out.println("false");
out.close();
LogOutput.log("bad data typr of the marketKey", LogOutput.ERROR);
LogOutput.flush();
return;
}
result = rsrActivateMarket(marketKey);
// out.println(result);
rsrFormMarketTab( out );
LogOutput.log("final: acrivate market (su)", LogOutput.INFO);
break;
case 5 :
// deactivate language (su)
LogOutput.log("start: deactivate language (su)", LogOutput.INFO);
try {
langKey = Integer.valueOf(req.getParameter(RSRConstants.sLangKey)).intValue();
} catch (NumberFormatException e) {
// bad input, report the error and do nothing
out.println("false");
out.close();
LogOutput.log("bad data type of the langKey", LogOutput.ERROR);
LogOutput.flush();
return;
}
result = rsrDeActivateLang(langKey);
// out.println(result);
rsrFormLangTab( out );
LogOutput.log("final: deactivate language (su)", LogOutput.INFO);
break;
case 6 :
// deactivate market (su)
LogOutput.log("start: deactivate market (su)", LogOutput.INFO);
try {
marketKey = Integer.valueOf(req.getParameter(RSRConstants.sMarketKey)).intValue();
} catch (NumberFormatException e) {
out.println("false");
out.close();
LogOutput.log("bad data type of the marketKey", LogOutput.ERROR);
LogOutput.flush();
return;
}
result = rsrDeActivateMarket(marketKey);
// out.println(result);
rsrFormMarketTab( out );
LogOutput.log("final: deactivate market (su)", LogOutput.INFO);
break;
case 7 :
// get all markets (su)
LogOutput.log("start: get all markets (su)", LogOutput.INFO);
String Markets = rsrGetMarkets();
out.print(Markets);
LogOutput.log("final: get all markets (su)", LogOutput.INFO);
break;
case 8 :
// get all languages with html interface for su-functions(su)
LogOutput.log("start: get all languages with html interface for su-functions(su)", LogOutput.INFO);
// out.print(rsrBuildHTMLLangInterFace());
rsrFormLangTab( out );
LogOutput.log("final: get all languages with html interface for su-functions(su)", LogOutput.INFO);
break;
case 9 :
// get all markets with html interface for su-functions(su)
LogOutput.log("start: get all markets with html interface for su-functions(su)", LogOutput.INFO);
// out.print(rsrBuildHTMLMarketInterFace());
rsrFormMarketTab( out );
LogOutput.log("final: get all markets with html interface for su-functions(su)", LogOutput.INFO);
break;
case 10 :
// build a list of all the active markets for validation
LogOutput.log("start: build a list of all the active markets for validation", LogOutput.INFO);
out.print(rsrBuildActiveMarketsList());
LogOutput.log("final: build a list of all the active markets for validation", LogOutput.INFO);
break;
case 11 :
// get get config page
rsrFormConfigParam(out);
break;
case 12 :
// change config parameters page
rsrChangeParams( req );
rsrFormConfigParam(out);
break;
case 13 :
// saves cfg file
rsrSaveCfgFile();
rsrFormConfigParam(out);
break;
case 14 :
// get add lag page
rsrFormAddLang( out );
break;
case 15 :
// get add page
rsrFormAddMarket( out);
break;
case 16 :
// re - init the servlet
rsrInit();
rsrFormOverview(out);
break;
}
LogOutput.flush();
out.close();
}
}