er.cpp
// Server.cpp
# include В«Header.hВ»
# include В«Extern.hВ»
DoServerProcess ()
{<<В«- ServerВ» <
// - З'єднання сервера з БД (містить інформацію)-hstmt;// ідентифікатор оператораhdbc;// ідентифікатор соедіненіяhenv;// ідентифікатор середовища
retcode;
dbase [] = В«Storage_В»;// ім'я БДuser [] = »»;// ім'я пользователяpasswd [] = »»;// пароль користувача (ProcRank, & dbase [7], 10);// дописуємо в назву бази ProcRank <<В«DB:В» <
sStorageID; szName [SIZE_BUF]; sSeries; szColor [SIZE_BUF]; sYear; sCost;
cbStorageID; cbName; cbSeries; cbColor; cbYear; cbCost;
// Назаначеніе ідентифікатора середовища = SQLAllocEnv (& henv); (SQL_SUCCESS! = retcode)
{(В«HENV Error! Exit n");
_getch (); -1;
}
// призначення ідентифікатора з'єднання = SQLAllocConnect (henv, & hdbc); (SQL_SUCCESS! = retcode)
{(В«HDBC Error! Exit n"); (henv);
_getch (); -1;
}
<<В«Connecting to DataBase ...В»; = SQLConnect (hdbc, (SQLCHAR *) dbase, _NTS, (SQLCHAR *) user, _NTS, (SQLCHAR *) passwd, _NTS);
(SQL_SUCCESS! = retcode)
{(В«Problem with connect to DB! Exit n"); (hdbc); (henv);
_getch (); -1;
} <<В«DONE!В» <
= SQLAllocStmt (hdbc, & hstmt); (SQL_SUCCESS! = retcode)
{(В«HSTMT Error! Exit n"); (hdbc); (hdbc); (henv);
_getch (); -1;
}
// - Цикл роботи сервера - (1)
{countRec = 0; _Recv (& countRec, 1, MPI_INT, MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, & Status); <<В«Count to receive:В» <
// виконання SQL-оператораmes [SIZE_BUF];// для відправки ** message = new char * [256];// не більше 256 рядків як результат SQL-запиту = SQLExecDirect (hstmt, ( SQLTCHAR *) (LPCTSTR) SQLStrRec, strlen (SQLStrRec)); (SQL_SUCCESS == retcode) ...
