在 IBM i 上使用 RPG 编程语言连接 MySQL 数据库的示例代码

本示例代码是一个简单的 RPG 程序，演示了如何连接 MySQL 数据库。其中使用了 ODBC 数据库连接方式。该程序可在 IBM i 操作系统上运行，并采用 IBM Rational Developer for i 进行编写。本例中将通过创建 DSN 连接来实现连接MySQL 数据库。

/**************************************************************
     * 功能：RPG 程序连接 MySQL 数据库
     * 编写者：IBM i 用户组
     * 编写软件：IBM Rational Developer for i
     * 软件版本号：V1R1M0
     **************************************************************/
     H actgrp(*CALLER) dftactgrp(*NO)
     D *NODATETIME *NOSHOWCPYSRC
     /include qsysinc/qrpglesrc,mysql
     /include qsysinc/qrpglesrc,odbc
     D Hdbc            S                   Like(sqlHdbc_t)
     D Hstmt           S                   Like(sqlHstmt_t)
     D ConnAttr        DS                  LikeDS(SQL_CONNECT_ATTR)
     D MysqlInfo       DS                  LikeDS(sqlMysql_t)
     D SqlState        DS                  LikeDS(sqlSqlState_t)
     D iError          S             10i 0 Inz(0)
     D Connection      S                   LikeDS(mysql_t)

     C/EXEC SQL
     C+  INCLUDE SQLCA;
     C/END-EXEC

     /**************************************************************/
     * 初始化 MYSQL 信息
     /**************************************************************/
     C                   Eval      MysqlInfo.Host    = '192.168.1.100';
     C                   Eval      MysqlInfo.Port    = 3306;
     C                   Eval      MysqlInfo.User    = 'root' ;
     C                   Eval      MysqlInfo.Pwd     = 'password';
     C                   Eval      MysqlInfo.DbName  = 'test';

     /**************************************************************/
     * 连接 MYSQL 数据库
     /**************************************************************/
     C                   Eval      iError = SQLConnectAttrs(ConnAttr%Addr);
     C                   Eval      iError = MysqlDBStartup(MysqlInfo%Addr, Connection%Addr);
     C                   Eval      iError = MysqlConnect(Connection%Addr);

     /**************************************************************/
     * 执行 SQL 语句
     /**************************************************************/
     C                   Eval      iError = SQLAllocHandle(SQL_HANDLE_STMT, Hdbc, %Addr(Hstmt));
     C                   Eval      iError = SQLExecDirect(Hstmt,
     C                                                       'select * from test' +
     C                                                       ' where id = ?',
     C                                                       SQL_NTS);

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com