Lotus и MySQL (jdbc)

import lotus.domino.*;
import java.util.Vector;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;
 
public class JavaAgent extends AgentBase {
 
public void NotesMain() {
 
try {
Session session = getSession();
AgentContext agentContext = session.getAgentContext();
 
// (Your code goes here)
Statement stmt = null;
ResultSet rs = null;
Connection conn = null;
 
try {
Class.forName("com.mysql.jdbc.Driver").newInstance();
} catch (Exception ex) {
System.out.println("SQLException: " + ex.getMessage());
 
}
 
 
try {
conn = DriverManager.getConnection("jdbc:mysql://server/dbname?user=USER&password=PASSWORD");
} catch (SQLException ex) {
System.out.println("On connect SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
}
System.out.println("Connection Created");
try {
stmt = conn.createStatement();
// Создаем временные таблицы
// 1. Наличие товара на складах по датам
String cutOffDate = "2006-10-16"; // дата отсечения
String tmpTableQuery = "CREATE TEMPORARY TABLE T1(guid integer, storeuid integer, days integer) SELECT guid, storeuid, count(distinct(storedate)) AS days FROM stores WHERE storedate>"+cutOffDate+" GROUP BY guid, storeuid ";
try {
stmt.executeUpdate(tmpTableQuery);
} catch(SQLException ex) {
System.out.println("Creating t1... SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
}
// 2. Текущее состояние складов
tmpTableQuery = "CREATE TEMPORARY TABLE T2(guid integer, storeuid integer, amount integer) SELECT guid,storeuid, sum(amount) AS amount FROM stores WHERE storedate = (SELECT MAX(storedate) FROM stores) GROUP BY guid, storeuid";
try {
stmt.executeUpdate(tmpTableQuery);
} catch(SQLException ex) {
System.out.println("Creating t2... SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
}
// 3. Продажи по датам
tmpTableQuery = "CREATE TEMPORARY TABLE T3(guid integer, storeuid integer, amount integer) SELECT guid, storeuid, sum(amount) AS amount FROM buystore WHERE indoccreatedate>"+cutOffDate+" GROUP BY guid, storeuid";
try {
stmt.executeUpdate(tmpTableQuery);
} catch(SQLException ex) {
System.out.println("Creating t3... SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
}
// ацкий JOIN
String joinQuery = "SELECT t1.*,goodslist.goodname, IFNULL(t2.amount,0) AS onstore, IFNULL(t3.amount,0) AS sold, ";
joinQuery = joinQuery + "IFNULL(t3.amount,0)/t1.days AS avrg, IFNULL(t3.amount,0)/t1.days-IFNULL(t2.amount,0) AS ness FROM t1 ";
joinQuery = joinQuery + "LEFT JOIN t2 ON t1.guid=t2.guid AND t1.storeuid=t2.storeuid ";
joinQuery = joinQuery + "LEFT JOIN t3 ON t1.guid=t3.guid AND t1.storeuid=t3.storeuid ";
joinQuery = joinQuery + "LEFT JOIN goodslist ON t1.guid=goodslist.guid ";
joinQuery = joinQuery + "WHERE IFNULL(t3.amount,0)/t1.days-IFNULL(t2.amount,0) >0 ";
joinQuery = joinQuery + "ORDER BY IFNULL(t3.amount,0)/t1.days-IFNULL(t2.amount,0)";
 
try {
rs = stmt.executeQuery(joinQuery);
} catch(SQLException ex) {
System.out.println("on JOIN SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
 
}
Database db = agentContext.getCurrentDatabase();
Document doc = db.createDocument();
doc.appendItemValue("Form", "ProductReport");
Vector vguid = new Vector();
Vector vgoodname = new Vector();
Vector vstoreuid = new Vector();
Vector vonstore = new Vector();
Vector vtobuy = new Vector();
while (rs.next()) {
// retrieve and print the values for the current row
Integer guid = new Integer(rs.getInt("guid"));
Integer storeuid = new Integer(rs.getInt("storeuid"));
Integer onstore = new Integer(rs.getInt("onstore"));
Float tobuy = new Float(rs.getFloat("ness"));
vguid.addElement(guid);
vgoodname.addElement(rs.getString("goodname"));
vstoreuid.addElement(storeuid);
vonstore.addElement(onstore);
vtobuy.addElement(tobuy);
}
doc.appendItemValue("guid",vguid);
doc.appendItemValue("goodname",vgoodname);
doc.appendItemValue("storeuid", vstoreuid);
doc.appendItemValue("onstore", vonstore);
doc.appendItemValue("tobuy", vtobuy);
doc.save();
} finally {
if (rs != null) {
try {
rs.close();
} catch(SQLException ex) {}
rs = null;
} //if
if (stmt != null) {
try {
stmt.close();
} catch(SQLException ex) {}
stmt = null;
} //if
} //finally
 
 
} catch(Exception e) {
e.printStackTrace();
}
}
}

import lotus.domino.*;
import java.sql.*;
 
public class JavaAgent extends AgentBase {
static Connection con;
static Statement stmt;
static ResultSet rs;
 
public void NotesMain() {
try {
Session session = getSession();
AgentContext agentContext = session.getAgentContext();
 
Class.forName("com.mysql.jdbc.Driver");
Connection con = DriverManager.getConnection("jdbc:mysql://ip_server:server_port/dbname", "user", "пароль");
Statement stmt = con.createStatement();
ResultSet rs=stmt.executeQuery("select * from test"); //в Sybase хранимку дергаю, так же как и select exec название проц. параметры через запятую
//ResultSet rs=stmt.executeQuery("exec prc_find_client 21160, 036-810/09ю, 252");
while (rs.next()) {
long s = rs.getLong(1); //здесь задаешь тип 1 колонки
long n = rs.getLong(2); //здесь задаешь тип 2 колонки
 
System.out.println(s + "  " + n);
}
//close all resources
stmt.close();
con.close();
} catch(Exception e) {
e.printStackTrace();
System.out.println("что-то не получилось(");
}
}
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;
 
class jMySQL {
private String name = "MySQL [JAVA]";
private Statement stmt = null;
private ResultSet rs = null;
private Connection conn = null;
private boolean DriverLoaded = false;
private boolean Connected = false;
private boolean SQL_EXEC = false;
 
private void Print(String Text){
System.out.println(name + ": " + Text);
}
 
public boolean InstallCharSet(String CharSetName)
{
try
{
if (!Connected)
{
Print("[InstallCharSet]: Не выполнено подключение!");
return false;
}
String SQL_CHAR = "SET character_set_results = "+CharSetName+", character_set_client = "+CharSetName+", character_set_connection = "+CharSetName+", character_set_database = "+CharSetName+", character_set_server = "+CharSetName+"";
stmt = conn.createStatement();
stmt.executeUpdate(SQL_CHAR);
return false;
} catch (Exception e) {
Print("[InstallCharSet]: " + e.getMessage());
return false;
}
}
 
public void GetMySQLInfo()
{
try
{
String SQLS = "SHOW VARIABLES";
stmt = conn.createStatement();
stmt.execute(SQLS);
rs = stmt.getResultSet();
} catch (Exception e) {
Print("-[GetMySQLInfo]---------------------------------------------");
e.printStackTrace();
}
 
}
 
public String real_escape_string(String SQLTEXT)
{
if (SQLTEXT.isEmpty())
{
return "";
}
 
if (SQLTEXT.replaceAll("[a-zA-Z0-9_!@#$%^&*()-=+~.;:,\\Q[\\E\\Q]\\E<>{}\\/? ]","").length() < 1)
{
return SQLTEXT;
}
 
String clean_string = SQLTEXT;
clean_string = clean_string.replaceAll("\\\\", "\\\\\\\\");
clean_string = clean_string.replaceAll("\\n","\\\\n");
clean_string = clean_string.replaceAll("\\r", "\\\\r");
clean_string = clean_string.replaceAll("\\t", "\\\\t");
clean_string = clean_string.replaceAll("\\00", "\\\\0");
clean_string = clean_string.replaceAll("", "\\\\");
clean_string = clean_string.replaceAll("\\\"", "\\\\\"");
 
return clean_string;
}
 
private boolean LoadDriver(){
try {
Class.forName("com.mysql.jdbc.Driver").newInstance();
DriverLoaded = true;
}
catch (Exception ex)
{
DriverLoaded = false;
}
return DriverLoaded;
}
 
public boolean Connect(String Host, String DataBase, String Login, String Password) {
if (Host.trim() == "" || DataBase.trim() == "" || Login.trim() == "" || Password.trim() == "")
{
Print("[Connect] Проверьте все ли параметры указаны!");
return false;
}
if (DriverLoaded != true){
Print("[Connect] Драйвер не загружен!");
Connected = false;
return false;
}
try {
conn = DriverManager.getConnection("jdbc:mysql://"+Host+"/"+DataBase+"?user="+Login+"&password="+Password);
Connected = true;
return true;
}
catch (SQLException ex)
{
Print("[Connect]: " + ex.getMessage() + " " + ex.getErrorCode());
Connected = false;
return false;
}
}
 
public boolean GetConnection(){
 
return Connected;
}
 
public boolean SQLExec(String Query){
if (!Connected)
{
Print("[SQLExec]: Не выполнено подключение!");
return false;
}
SQL_EXEC = false;
try {
stmt = conn.createStatement();
if (stmt.execute(Query)) {
rs = stmt.getResultSet();
SQL_EXEC = true;
return true;
} else
{
SQL_EXEC = false;
return false;
}
} catch (Exception ex) {
SQL_EXEC = false;
Print("[SQLExec]: " + ex.getMessage());
return false;
}
}
 
public boolean Disconnect(){
try
{
rs.close();
return true;
} catch (Exception ex) {
Print("[Disconnect]: " + ex.getMessage());
return false;
}
}
 
public ResultSet Result() {
if (!SQL_EXEC) {
return null;
} else
{
return rs;
}
}
 
public jMySQL() {
try
{
LoadDriver();
}
catch (Exception ex)
{
Print("[jMySQL]: " + ex.getMessage());
}
}
 
}

    private void ExportDep(Database db) {
Document doc;
View view;
try {
Print("[OK] - Составление списка управлений из модуля Шлюз...!");
/* Фиксируем время начало выполнения агента */
view = db.getView("depByName");
Print("[OK] - Найдено документов: " + view.getEntryCount());
if (view.getEntryCount() == 0)
{
Print("[W] - Не найдено ни одного управления, завершение выполнение агента!");
return;
}
/* Очищаем таблицу от старых записей, для загрузки более актуальной информации */
Print("[OK] - Очистка таблицы MySQL...!");
SQL = "TRUNCATE TABLE `dep_list`";
SQLEXECR = MySQL.SQLExec(SQL);
Print("[OK] - Очистка завершена!");
Print("[OK] - Начинаем выгрузку данных в MySQL...");
/* Перебираем документы и выполняем запрос на добавлении их в MySQL базу */
doc = view.getFirstDocument();
 
while (doc != null) {
/* Получение данных из текущего документа,а так же проверка некоторых обязательных полей */
String dep_id = doc.getItemValueString("fDUnid");
String dep_name = doc.getItemValueString("fDName");
String dep_namekz = doc.getItemValueString("fDNameKZ");
 
String dep_address = doc.getItemValueString("fDAddress");
String dep_leader = doc.getItemValueString("fDLeader");
String dep_leader_contact = doc.getItemValueString("fDLeader_ContactInfo");
String dep_leader_email = doc.getItemValueString("fDLeader_ContactEmail");
String dep_citizen = doc.getItemValueString("fDCitizen_FIO");
String dep_citizen_contact = doc.getItemValueString("fDCitizen_ContactInfo");
String dep_sort_id = doc.getItemValueString("fDSortID").trim();
 
dep_sort_id = dep_sort_id.isEmpty()?"300":dep_sort_id;
 
 
/* Экранизация данных - предотвращает ошибки при отправки SQL запросов */
dep_name = MySQL.real_escape_string(dep_name);
dep_namekz = MySQL.real_escape_string(dep_namekz);
dep_address = MySQL.real_escape_string(dep_address);
dep_leader_contact = MySQL.real_escape_string(dep_leader_contact);
dep_leader_email = MySQL.real_escape_string(dep_leader_email);
dep_citizen_contact = MySQL.real_escape_string(dep_citizen_contact);
 
 
/* Подготовка SQL Запроса */
SQL = "INSERT INTO `dep_list` " +
"(`dep_id`,`dep_name`,`dep_namekz`,`dep_address`,`" +
"dep_leader`,`dep_leader_contact`,`dep_leader_email`,`dep_citizen`," +
"`dep_citizen_contact`,`dep_sort_id`)";
SQL += "VALUES(";
SQL +=  ""+dep_id+","+dep_name+","+dep_namekz+","+dep_address+"," +
""+dep_leader+","+dep_leader_contact+","+dep_leader_email+","+dep_citizen+"," +
""+dep_citizen_contact+", "+dep_sort_id+")";
 
/* Отправка запроса */
SQLEXECR = MySQL.SQLExec(SQL);
/* Получаем следующий документ */
doc = view.getNextDocument(doc);
}
MySQL.SQLExec(SQL);
Print("[OK] - Запись в таблицу обновлений внесена!");
Print("[OK] - Выполнение синхронизации завершено!");
Print("------------------------------------------------------------------");
} catch (Exception e) {
Print("[ER] - Текст ошибки: " + e.getMessage() + " Код ошибки: " + e.hashCode());
e.printStackTrace();
}
}

function bool function SQL_EXEC(String SQL, params)
{
...
}

     public PreparedStatement SetPreparedStatementSQLExec_Use(String Query) {
try {
return (PreparedStatement) conn.prepareStatement(Query);
} catch (SQLException e) {
e.printStackTrace();
return null;
}
}

setLong(1, 123456789);

import lotus.domino.*;
import java.util.*;
import java.io.PrintWriter;
import java.text.*;
 
public class MySQLExport extends AgentBase {
jMySQL MySQL = new jMySQL();
String AgentName = "Export2SQL";
String SQL = "";
int NCount = 0;
Database db = null;
Document profile = null;
PrintWriter PW = null;
 
boolean SQLEXECR = false;
 
/* Получить текущую дату */
private String getDateTime(String format) {
format = format.isEmpty()?"dd.MM.yyyy hh:mm:ss":format;
DateFormat dateFormat = new SimpleDateFormat(format);
Date date = new Date();
return dateFormat.format(date);
}
 
/* метод для конверации даты в дату в формате UNIX */
private long StrToDateUnix(String datatime, String format)
{
try
{
format = format.isEmpty()?"dd.MM.yyyy hh:mm:ss":format;
DateFormat formatter = new SimpleDateFormat("dd.MM.yyyy hh:mm:ss");
Date date2 = formatter.parse(datatime);
return (long)date2.getTime() / 1000L;
} catch (Exception e) {
return -1;
}
}
 
/* Аналог функции Print в LS */
private void Print(String Text){
System.out.println(AgentName + ": " +Text);
}
 
private void ExportNotice(Database db) {
Document doc = null;
View view = null;
Document ntTmp = null;
 
try {
try {
Print("[OK] - Поиск уведомлений в модуле Шлюз...!");
view = db.getView("noticesByUniqueNum");
NCount = view.getEntryCount();
Print("[OK] - Найдено уведомлений: " + NCount);
if (NCount == 0)
{
Print("[W] - Не найдено ни одного докумета, завершение выполнение агента!");
return;
}
/* Очищаем таблицу от старых записей, для загрузки более актуальной информации */
Print("[OK] - Очистка таблицы уведомлений в MySQL...!");
SQL = "TRUNCATE TABLE `notice`";
SQLEXECR = MySQL.SQLExec(SQL);
Print("[OK] - Очистка завершена!");
Print("[OK] - Начинаем выгрузку уведомлений в MySQL...");
/* Перебираем документы и выполняем запрос на добавлении их в MySQL базу */
doc = view.getFirstDocument();
 
while (doc != null) {
/* Получение данных из текущего документа,а так же проверка некоторых обязательных полей */
String fnRegNum = doc.getItemValueString("fnRegNum");
String fnSendet = doc.getItemValueString("fnSendet");
long fnDataTime = StrToDateUnix( doc.getItemValueString("fnDataTime"), "");
String fnDepID = !doc.getItemValueString("fnDepID").isEmpty()?doc.getItemValueString("fnDepID").trim():"0";
String fnDepIDTo = !doc.getItemValueString("fnDepIDTo").isEmpty()?doc.getItemValueString("fnDepIDTo").trim():"0";
String fnOrganization = doc.getItemValueString("fnOrganization");
String fnAppName = doc.getItemValueString("fnAppName");
String fnAppEmail = doc.getItemValueString("fnAppEmail");
String fnAppMPhone = doc.getItemValueString("fnAppMPhone");
String fnCategory = !doc.getItemValueString("fnCategory").isEmpty()?doc.getItemValueString("fnCategory").trim():"0";
String fNStatIndex = !doc.getItemValueString("fNStatIndex").isEmpty()?doc.getItemValueString("fNStatIndex").trim():"0";
String fNStatText = doc.getItemValueString("fNStatText");
long fNStatExpire = StrToDateUnix( doc.getItemValueString("fNStatExpire") + " 00:00:00", "");
String fnExName = doc.getItemValueString("fnExName");
String fnExPost = doc.getItemValueString("fnExPost");
String fnUniqNum = doc.getItemValueString("fnUniqNum");
long fnCreateTime = StrToDateUnix( doc.getItemValueString("fnCreateTime"), "");
 
/* Экранизация данных - предотвращает ошибки при отправки SQL запросов */
fnRegNum = MySQL.real_escape_string(fnRegNum);
fnOrganization = MySQL.real_escape_string(fnOrganization);
fnAppName = MySQL.real_escape_string(fnAppName);
fnAppEmail = MySQL.real_escape_string(fnAppEmail);
fNStatText = MySQL.real_escape_string(fNStatText);
fnExPost = MySQL.real_escape_string(fnExPost);
fnExName = MySQL.real_escape_string(fnExName);
fnUniqNum = MySQL.real_escape_string(fnUniqNum);
 
 
/* Подготовка SQL Запроса */
SQL = "INSERT INTO `notice` " +
"(`fnRegNum`,`fnSendet`,`fnDataTime`,`" +
"fnDepID`,`fnDepIDTo`,`fnOrganization`,`fnAppName`," +
"`fnAppEmail`,`fnAppMPhone`,`fnCategory`,`fNStatIndex`," +
"`fNStatText`,`fNStatExpire`,`fnExName`,`fnExPost`,`fnUniqNum`, `fnCreateTime`)";
SQL += "VALUES(";
SQL +=  ""+fnRegNum.trim()+","+fnSendet.trim()+","+fnDataTime+"," +
""+fnDepID.trim()+","+fnDepIDTo.trim()+","+fnOrganization.trim()+","+fnAppName.trim()+"," +
""+fnAppEmail.trim()+","+fnAppMPhone.trim()+","+fnCategory.trim()+","+fNStatIndex.trim()+"," +
""+fNStatText.trim()+","+fNStatExpire+","+fnExName.trim()+","+fnExPost.trim()+","+fnUniqNum.trim()+", "+fnCreateTime+")";
 
/* Отправка запроса */
/*Print(SQL); */
SQLEXECR = MySQL.SQLExec(SQL);
/* Получаем следующий документ */
 
ntTmp = doc;
doc = null;
doc = view.getNextDocument(ntTmp);
ntTmp.recycle();
}
Print("[OK] - Экспорт уведомлений завершен!");
Print("------------------------------------------------------------------");
} catch (Exception e) {
Print("[ER] - Текст ошибки: " + e.getMessage() + " Код ошибки: " + e.hashCode());
e.printStackTrace();
}
} finally {
doc = null;
view = null;
ntTmp = null;
}
 
}
 
private void ExportDep(Database db) {
Document doc = null;
View view = null;
Document ntTmp = null;
 
try {
try {
Print("[OK] - Составление списка управлений из модуля Шлюз...!");
view = db.getView("depByName");
Print("[OK] - Найдено документов: " + view.getEntryCount());
if (view.getEntryCount() == 0)
{
Print("[W] - Не найдено ни одного управления, завершение выполнение агента!");
return;
}
/* Очищаем таблицу от старых записей, для загрузки более актуальной информации */
Print("[OK] - Очистка таблицы MySQL...!");
SQL = "TRUNCATE TABLE `dep_list`";
SQLEXECR = MySQL.SQLExec(SQL);
Print("[OK] - Очистка завершена!");
Print("[OK] - Начинаем выгрузку данных в MySQL...");
/* Перебираем документы и выполняем запрос на добавлении их в MySQL базу */
doc = view.getFirstDocument();
 
while (doc != null) {
/* Получение данных из текущего документа,а так же проверка некоторых обязательных полей */
String dep_id = doc.getItemValueString("fDUnid");
String dep_name = doc.getItemValueString("fDName");
String dep_namekz = doc.getItemValueString("fDNameKZ");
 
String dep_address = doc.getItemValueString("fDAddress");
String dep_leader = doc.getItemValueString("fDLeader");
String dep_leader_contact = doc.getItemValueString("fDLeader_ContactInfo");
String dep_leader_email = doc.getItemValueString("fDLeader_ContactEmail");
String dep_citizen = doc.getItemValueString("fDCitizen_FIO");
String dep_citizen_contact = doc.getItemValueString("fDCitizen_ContactInfo");
int dep_sort_id = (int) doc.getItemValueInteger("fDSortID");
 
dep_sort_id = dep_sort_id <=0?300:dep_sort_id;
 
 
/* Экранизация данных - предотвращает ошибки при отправки SQL запросов */
dep_name = MySQL.real_escape_string(dep_name);
dep_namekz = MySQL.real_escape_string(dep_namekz);
dep_address = MySQL.real_escape_string(dep_address);
dep_leader_contact = MySQL.real_escape_string(dep_leader_contact);
dep_leader_email = MySQL.real_escape_string(dep_leader_email);
dep_citizen_contact = MySQL.real_escape_string(dep_citizen_contact);
 
 
/* Подготовка SQL Запроса */
SQL = "INSERT INTO `dep_list` " +
"(`dep_id`,`dep_name`,`dep_namekz`,`dep_address`,`" +
"dep_leader`,`dep_leader_contact`,`dep_leader_email`,`dep_citizen`," +
"`dep_citizen_contact`,`dep_sort_id`)";
SQL += "VALUES(";
SQL +=  ""+dep_id+","+dep_name+","+dep_namekz+","+dep_address+"," +
""+dep_leader+","+dep_leader_contact+","+dep_leader_email+","+dep_citizen+"," +
""+dep_citizen_contact+", "+dep_sort_id+")";
 
/* Отправка запроса */
SQLEXECR = MySQL.SQLExec(SQL);
/* Получаем следующий документ */
 
ntTmp = doc;
doc = null;
doc = view.getNextDocument(ntTmp);
ntTmp.recycle();
}
 
MySQL.SQLExec(SQL);
Print("[OK] - Запись в таблицу обновлений внесена!");
Print("[OK] - Экспорт списка управлений завершен!");
Print("------------------------------------------------------------------");
} catch (Exception e) {
Print("[ER] - Текст ошибки: " + e.getMessage() + " Код ошибки: " + e.hashCode());
e.printStackTrace();
}
} finally {
doc = null;
view = null;
ntTmp = null;
}
 
}
 
private void ExportStatus(Database db) {
Document doc = null;
View view = null;
Document ntTmp = null;
 
try {
try {
Print("[OK] - Составление списка статусов из модуля Шлюз...!");
view = db.getView("vInf_Status");
Print("[OK] - Найдено статусов: " + view.getEntryCount());
if (view.getEntryCount() == 0)
{
Print("[W] - Не найдено ни одного статуса, завершение выполнение агента!");
return;
}
/* Очищаем таблицу от старых записей, для загрузки более актуальной информации */
Print("[OK] - Очистка таблицы MySQL...!");
SQL = "TRUNCATE TABLE `status_list`";
SQLEXECR = MySQL.SQLExec(SQL);
Print("[OK] - Очистка завершена!");
Print("[OK] - Начинаем выгрузку данных в MySQL...");
/* Перебираем документы и выполняем запрос на добавлении их в MySQL базу */
doc = view.getFirstDocument();
 
while (doc != null) {
/* Получение данных из текущего документа,а так же проверка некоторых обязательных полей */
String status_id = doc.getItemValueString("fSUid");
String status_name = doc.getItemValueString("fSNameRU");
String status_namekz = doc.getItemValueString("fSNameKZ");
 
 
/* Подготовка SQL Запроса */
SQL = "INSERT INTO `status_list` " +
"(`status_id`,`status_name`,`status_namekz`)";
SQL += "VALUES(";
SQL +=  ""+status_id+","+status_name+","+status_namekz+")";
 
/* Отправка запроса */
SQLEXECR = MySQL.SQLExec(SQL);
/* Получаем следующий документ */
ntTmp = doc;
doc = null;
doc = view.getNextDocument(ntTmp);
ntTmp.recycle();
}
 
 
MySQL.SQLExec(SQL);
Print("[OK] - Экспорт статусов завершен!");
Print("------------------------------------------------------------------");
} catch (Exception e) {
Print("[ER] - Текст ошибки: " + e.getMessage() + " Код ошибки: " + e.hashCode());
e.printStackTrace();
}
} finally {
doc = null;
view = null;
ntTmp = null;
}
 
 
}
/* Основной инициируемый метод */
public void NotesMain() {
PW=getAgentOutput();
/* Фиксируем время начало выполнения агента */
long StartTime = System.currentTimeMillis() / 1000;
Session session = getSession();
 
try{
 
try {
/* Выполнение */
Print("[!] - Инициализция агента синхронизации с MySQL сервером!" );
 
db = session.getAgentContext().getCurrentDatabase();
Print("[!] - Получение настроек агента!" );
profile = db.getProfileDocument("fProfile", "");
 
if (profile == null)
{
Print("[!] - Проверьте настройки в базе!" );
return;
}
 
String Run = profile.getItemValueString("fPMysqlEnabled");
String Login = profile.getItemValueString("fPMysqlLogin");
String Password = profile.getItemValueString("fPMysqlPassword");
String DBName = profile.getItemValueString("fPMysqlDataBaseName");
String Host = profile.getItemValueString("fPMysqlHost");
 
if (Run.isEmpty())
{
Print("[!] - Агент отключен. Проверьте настройки в базе!" );
return;
}
 
boolean cnt = MySQL.Connect(Host, DBName, Login, Password);
if (!cnt)
{
Print("[ER] - Не удалось соедениться с сервером MySQL. Продробности об ошибке смотрете в логах сервера!");
return;
}
 
Print("[OK] - Платформа: " + System.getProperty("os.name"));
Print("[OK] - Соединение с MySQL сервером прошло успешно!");
 
/* Экспорт статусов */
ExportStatus(db);
/* Экспорт списка управлений */
ExportDep(db);
/* Экспорт формы уведомлений */
ExportNotice(db);
 
/* UNIX время завершения выполнения агента */
long EndTime = System.currentTimeMillis() / 1000;
 
 
long CurrentDate = StrToDateUnix(getDateTime("dd.MM.yyyy") + " 00:00:00", "");
 
SQL = "INSERT INTO `notice_update` (`date_update`, `last_update`, `start_update`, `recordcount`) VALUES ("+CurrentDate+", "+StartTime+","+EndTime+","+NCount+")";
MySQL.SQLExec(SQL);
 
SQL = "INSERT INTO notice_logupdate (`day_id`,`start_time`, `end_time`, `recordcount`) VALUES ("+CurrentDate+", "+StartTime+", "+EndTime+", "+NCount+") " +
"ON DUPLICATE KEY UPDATE start_time="+StartTime+", end_time="+EndTime+", recordcount="+NCount+"";
 
MySQL.SQLExec(SQL);
Print("[OK] - Синхронизация успешно завершена");
PW.println("Content-type: text/plain; charser: utf-8");
PW.println("OK");
} catch (Exception e) {
Print("[ER] - Текст ошибки: " + e.getMessage() + " Код ошибки: " + e.hashCode());
e.printStackTrace();
}
 
}
finally {
PW = null;
MySQL = null;
profile = null;
db = null;
}
 
 
 
}
}