Эбберс М. Введение в современные мейнфреймы: основы z/OS
Подождите немного. Документ загружается.
Пакетная программа доступа к DB2 на языке C
Исходный код
Эта программа находится в разделе CDB2 библиотеки GMULLER.TEST.C.
Пример E.1. Исходный код программы доступа к DB2 на языке C
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
EXEC SQL INCLUDE SQLCA;
EXEC SQL INCLUDE SQLDA;
EXEC SQL
DECLARE DSN8810.EMP TABLE
(EMPNO CHAR(6) NOT NULL,
FIRSTNAME VARCHAR(12) NOT NULL,
MIDINIT CHAR(1) NOT NULL,
LASTNAME VARCHAR(15) NOT NULL,
WORKDEPT CHAR(3) ,
PHONENO CHAR(4) ,
HIREDATE DATE ,
JOB CHAR(8) ,
EDLEVEL SMALLINT ,
SEX CHAR(1) ,
BIRTHDATE DATE ,
SALARY DECIMAL(9,2) ,
BONUS DECIMAL(9,2) ,
COMM DECIMAL(9,2) );
EXEC SQL BEGIN DECLARE SECTION;
long sum;
long count;
char deptno[4];
EXEC SQL END DECLARE SECTION;
int avg_sal(char*);
int record_read(FILE*,char*);
void main()
{
FILE* cardin; /* for DD card CARDIN */
int avgsal;
char dept[4];
cardin = fopen(«DD:CARDIN»,«rb,recfm=FB,lrecl=80,type=record»);
if(cardin == NULL) {
printf(«Error opening DD CARDIN\n»);
exit(-2);
}
562 ПриложениеE
Программадляпрактическойработы 563
while(record_read(cardin, dept) != 0) {
avgsal = avg_sal(dept);
if(avgsal > 0)
printf(«Average salary of %s is %d\n»,dept, avgsal);
}
fclose(cardin);
}
int avg_sal(char* dept)
{
int avgsal;
count = 0;
strncpy(deptno, dept, 3);
deptno[3] = 0;
EXEC SQL SELECT SUM(SALARY), COUNT(*) INTO :sum, :count
FROM DSN8810.EMP
WHERE WORKDEPT = :deptno;
if(count != 0) {
avgsal = sum/count;
return avgsal;
} else {
printf(«DEPT %s does not exist\n», deptno);
return -1;
}
}
int record_read(FILE* file, char* dept)
{
int readbytes;
char linebuf[81], linebuf2[80];
readbytes = fread(linebuf, 1, 81, file);
strncpy(dept, linebuf, 3); /* first 3 bytes are dept. number */
dept[3]=0; /* terminate string */
return readbytes;
}
Подготовка программы
Этот JCL находится в разделе CDB2 библиотеки GMULLER.TEST.CNTL.
Пример E.2. GMULLER.TEST.CNTL(CDB2)
//GMULLERC JOB 1,GEORG,MSGLEVEL=(1,1),NOTIFY=&SYSUID
//* PRECOMPILE AND COMPILE THE SAMPLE C FILE
//PROCLIB JCLLIB ORDER=DB8HU.PROCLIB
/*JOBPARM SYSAFF=SC04
//STEP1 EXEC PROC=DSNHC,MEM=CDB2,
// PARM.PC=('HOST(C),CCSID(1047)')
//PC.DBRMLIB DD DSN=DB8HU.DBRMLIB.DATA(CDB2),DISP=SHR
564 ПриложениеЕ
//PC.SYSLIB DD DSN=GMULLER.TEST.C,DISP=SHR
//PC.SYSIN DD DSN=GMULLER.TEST.C(&MEM),DISP=SHR
//LKED.SYSLMOD DD DSN=GMULLER.TEST.LOAD(&MEM),DISP=SHR
//LKED.SYSIN DD *
INCLUDE SYSLIB(DSNELI)
//****************************************************
//* BIND AND RUN THE PROGRAM *
//****************************************************
//BIND EXEC PGM=IKJEFT01,DYNAMNBR=20,COND=(4,LT)
//STEPLIB DD DSN=DB8H8.SDSNLOAD,DISP=SHR
//DBRMLIB DD DSN=DB8HU.DBRMLIB.DATA,DISP=SHR
//SYSUDUMP DD SYSOUT=*
//SYSTSPRT DD SYSOUT=*
//SYSPRINT DD SYSOUT=*
//CARDIN DD *
D11
XYZ
A00
/*
//SYSIN DD *
GRANT BIND,EXECUTE ON PLAN CDB2 TO PUBLIC;
//SYSTSIN DD *
DSN SYSTEM(DB8H)
BIND PACKAGE (CDB2PAK) MEMBER(CDB2) -
ACT(REP) ISO(CS) ENCODING(EBCDIC)
BIND PLAN(CDB2) PKLIST(CDB2PAK.*) -
ACT(REP) ISO(CS) ENCODING(EBCDIC)
RUN PROGRAM(CDB2) PLAN(CDB2) LIB('GMULLER.TEST.LOAD')
END
/*
• Это задание требует PDS GMULLER.TEST.LOAD с RECFM=U.
• Оператор «/*JOBPARM SYSAFF=SC04» указывает на систему, в которой запущен
DB2; этот оператор нужно изменить (или удалить, если не используется сисп-
лекс).
• DB8H нужно заменить именем локальной DB2.
• HLQ для библиотек DB2 могут отличаться.
Выходные данные
Пример E.3. Выходные данные CDB2
Average salary of D11 is 25147
DEPT XYZ does not exist
Average salary of A00 is 40850
Программадляпрактическойработы 565
Выполнение программы
Этот JCL находится в разделе RUNJCL библиотеки GMULLER.TEST.CNTL.
Пример E.4. GMULLER.TEST.CNTL(RUNJCL)
//GMULLERR JOB 1,GEORG,MSGLEVEL=(1,1),NOTIFY=&SYSUID
//* PRECOMPILE AND COMPILE THE SAMPLE C FILE
/*JOBPARM SYSAFF=SC04
//****************************************************
//* RUN THE PROGRAM *
//****************************************************
//BIND EXEC PGM=IKJEFT01,DYNAMNBR=20,COND=(4,LT)
//STEPLIB DD DSN=DB8H8.SDSNLOAD,DISP=SHR
//DBRMLIB DD DSN=DB8HU.DBRMLIB.DATA,DISP=SHR
//SYSUDUMP DD SYSOUT=*
//SYSTSPRT DD SYSOUT=*
//SYSPRINT DD SYSOUT=*
//CARDIN DD DISP=SHR,DSN=GMULLER.TEST.CNTL(CARDIN)
//SYSTSIN DD *
DSN SYSTEM(DB8H)
RUN PROGRAM(CDB2) PLAN(CDB2) LIB('GMULLER.TEST.LOAD')
END
/*
• Этот пример требует раздел CARDIN в библиотеке GMULLER.TEST.CNTL
• HLQ для библиотек DB2 могут отличаться.
Входные данные
Пример E.5. GMULLER.TEST.CNTL(CARDIN)
D11
A00
XYZ
C01
ABC
E21
Выходные данные
Пример E.6. Выходные данные RUNJCL
Average salary of D11 is 25147
Average salary of A00 is 40850
DEPT XYZ does not exist
Average salary of C01 is 29722
DEPT ABC does not exist
Average salary of E21 is 24086
Доступ Jaa-сервлета к DB2
Исходный код сервлета
Пример E.7. SalaryServlet.java
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
public class SalaryServlet extends HttpServlet {
private DataSource ds;
private boolean dbProblem = false;
public void init() throws ServletException {
super.init();
try { // get DataSource from Container
Context context = new InitialContext();
ds = (DataSource) context.lookup(“jdbc/DB8H”);
} catch (NamingException e) {
e.printStackTrace();
this.dbProblem = true;
}
}
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
resp.setContentType(“text/html”);
String deptno = req.getParameter(“deptno”); // get from request string
PrintWriter out = resp.getWriter();
out.println(“<html>\n<head>\n <title>Average
Salary</title>\n</head>\n<body>”);
out.println(“<h1>Average Salary</h1>”);
out.println(“<form action=\”salary\” method=\”get\”>”);
out.println(“Dept. No.: <input type=\”text\” name=\”deptno\” />”);
566 ПриложениеЕ
Программадляпрактическойработы 567
out.println(“ <input type=\”submit\” />\n</form>”);
if (deptno != null) {
try {
int avgSal = getAvgSal(deptno);
out.println(“The average salary of <b>” + deptno
+ “</b> is <b>$ “ + avgSal
+ “</b><br>”);
} catch (Exception e) {
out.println(“<b>Error: “ + e.getMessage() +
“</b><br>”);
}
}
out.println(“</html>”);
}
private int getAvgSal(String deptno) throws Exception {
String sqlStatement = “SELECT SUM(salary), COUNT(*) “
+ “FROM DSN8810.EMP WHERE WORKDEPT = ‘” + deptno + “’”;
// Connect to database
Connection con = null;
try {
con = ds.getConnection();
Statement stmt = con.createStatement();
ResultSet rs
= stmt.executeQuery(sqlStatement);// Execute SQL
// statement
rs.next(); // get Values from result set
int sum = rs.getInt(1);
int count = rs.getInt(2);
if (count == 0)
throw new Exception("Department " + deptno
+ “ does not exist”);
return sum / count;
} catch (SQLException e) {
throw new Exception(e.getMessage());
} finally {
try {
con.close();
} catch (SQLException e) {}
}
}
}
• Этот сервлет требует определения источника данных (в данном случае JNDI
с именем «jdbc/DB8H»), определенного в веб-контейнере, указывающего на
базу данных DB2
568 ПриложениеЕ
Дескриптор развертывания
Пример E.8. web.xml
<?xml version=»1.0» encoding=»UTF-8»?>
<!DOCTYPE web-app PUBLIC «-//Sun Microsystems, Inc.//DTD Web
Application 2.3//EN» «http://java.sun.com/dtd/web-app_2_3.dtd»>
<web-app id=»WebApp_ID»>
<display-name>Salary</display-name>
<servlet>
<servlet-name>Salary</servlet-name>
<servlet-class>SalaryServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>Salary</servlet-name>
<url-pattern>/salary</url-pattern>
</servlet-mapping>
</web-app>
Программа доступа к MQ на языке C
MQPUT записывает сообщение в очередь (вводится в TSO).
Программа запускается командой TSO CALL ‘ZSCHOLAR.PROGRAM.LOAD(MQPUT)’,
после чего необходимо ввести сообщение.
MQGET получает сообщение обратно и выводит его на экране.
Программа запускается командой TSO CALL ‘ZSCHOLAR.PROGRAM.LOAD(MQGET)’,
после чего необходимо ввести сообщение.
Также можно принять сообщение, используя Java-приложение из раздела «Про-
грамма доступа к MQ на языке Java».
MQPUT
Пример E.9. ZSCHOLAR.PROGRAM.SRC(MQPUT)
#pragma csect(code,»CSQ4BCK1»)
/* */
/* Define static CSECT name */
/* */
#pragma csect(static,»BCK1WS»)
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <cmqc.h>
/* */
Программадляпрактическойработы 569
/* Function prototypes */
/* */
void usageError( char* programName );
void errorMessage( char* msgStr, MQLONG CC, MQLONG RC );
int main( int argc, char** argv )
{
/* */
/* API variables */
/* */
MQHCONN HConn = MQHC_DEF_HCONN;
MQHOBJ HObj;
MQLONG OpenOptions;
MQMD MsgDesc = { MQMD_DEFAULT };
MQOD ObjDesc = { MQOD_DEFAULT };
MQPMO PutMsgOpts = { MQPMO_DEFAULT };
MQLONG CompCode;
MQLONG Reason;
/* */
/* Parameter variables */
/* */
MQCHAR48 qMgr;
MQCHAR48 qName;
char msgBuffer[255];
int msgLength;
char persistent = 'N';
long rc = 0;
printf(«Please enter message text:\n»);
fgets(msgBuffer, 255, stdin);
msgLength = strlen(msgBuffer);
strcpy( qMgr, «MQ8H\0» );
strcpy( qName, «GMULLER\0» );
/*
memset( qMgr, '\0', MQ_Q_MGR_NAME_LENGTH );
memset( qName, '\0', MQ_Q_NAME_LENGTH );
*/
/* */
/* Connect to Queue Manager (MQCONN) */
/* */
MQCONN( qMgr,
&HConn,
&CompCode,
&Reason );
/* */
/* If connect failed then display error message and exit */
/* */
if( MQCC_OK != CompCode ) {
errorMessage( «MQCONN», CompCode, Reason );
return Reason;
}
printf( «MQCONN SUCCESSFUL\n» );
/* */
/*
Open Queue for output (MQOPEN). Fail the call if the queue */
/* manager is quiescing. */
/* */
OpenOptions = MQOO_OUTPUT +
MQOO_FAIL_IF_QUIESCING;
strncpy( ObjDesc.ObjectName, qName, MQ_Q_NAME_LENGTH );
MQOPEN( HConn,
&ObjDesc,
OpenOptions,
&HObj,
&CompCode,
&Reason );
/* */
/* If open failed then display error message, */
/* disconnect from the queue manager and exit */
/* */
if( MQCC_OK != CompCode ) {
errorMessage( «MQOPEN», CompCode, Reason );
rc = Reason;
MQDISC( &HConn,
&CompCode,
&Reason );
return rc;
}
printf( «MQOPEN SUCCESSFUL\n» );
/* */
/* Set persistence depending on parameter passed */
/* */
if( 'P' == persistent )
MsgDesc.Persistence = MQPER_PERSISTENT;
else
MsgDesc.Persistence = MQPER_NOT_PERSISTENT;
/* */
/* Put String format messages */
strncpy( MsgDesc.Format, MQFMT_STRING, MQ_FORMAT_LENGTH );
/* */
/*
Set the put message options to fail the call if the queue */
570 ПриложениеE
Программадляпрактическойработы 571
/* manager is quiescing. */
/* */
PutMsgOpts.Options = MQPMO_FAIL_IF_QUIESCING;
strncpy( MsgDesc.MsgId, MQMI_NONE, MQ_MSG_ID_LENGTH );
strncpy( MsgDesc.CorrelId, MQCI_NONE, MQ_CORREL_ID_LENGTH );
MQPUT( HConn,
HObj,
&MsgDesc,
&PutMsgOpts,
msgLength,
msgBuffer,
&CompCode,
&Reason );
/*
/* If put failed then display error message */
/* and break out of loop */
/* */
if( MQCC_OK != CompCode )
{
errorMessage( «MQPUT», CompCode, Reason );
rc = Reason;
}
printf(«MESSAGE PUT TO QUEUE\n»);
free( msgBuffer );
/* */
/*
Close the queue and then disconnect from the queue manager */
/* */
MQCLOSE( HConn,
&HObj,
MQCO_NONE,
&CompCode,
&Reason );
if( MQCC_OK != CompCode )
{
errorMessage( «MQCLOSE», CompCode, Reason );
rc = Reason;
}
else printf( «MQCLOSE SUCCESSFUL\n» );
MQDISC( &HConn,
&CompCode,
&Reason );
if( MQCC_OK != CompCode )
{
errorMessage( «MQDISC», CompCode, Reason );