参数标记

参数标记通常用问号（?）或冒号并后跟变量名 (:var1) 表示，在 SQL 语句中充当其值在执行语句期间获取的占位符。

应用程序使参数标记与应用程序变量相关联。在执行语句期间，这些变量的值将分别替换每个参数标记。该过程期间可能会发生数据转换。

参数标记的优点

对于需要多次执行的 SQL 语句，预编译 SQL 语句一次，然后通过在运行时期间使用参数标记来替代输入值以重复使用查询方案通常很有利。参数标记用下列两种方法的其中一种表示：

第一种样式带有“?” 字符，用于动态 SQL 执行（动态嵌入式 SQL、CLI、Perl 等）。
第二种样式表示嵌入式 SQL 标准构造，其中变量名称以冒号为前缀（:var1）。此样式用于静态 SQL 执行，并且通常称为主变量。

使用任一样式指示应用程序变量将在 SQL 语句内被替代。参数标记是按编号引用的，并且按从左至右，从 1 开始的号码顺序编号。执行 SQL 语句之前，应用程序必须将变量存储区域绑定至 SQL 语句中指定的每个参数标记。此外，绑定变量必须是有效存储区域，并且在对数据库执行预编译语句时必须包含输入数据值。

以下示例说明包含两个参数标记的 SQL 语句。

SELECT * FROM customers WHERE custid = ? AND lastname = ?

受支持的类型

可在 SQL 语句的所选位置指定隐式类型参数标记。表 1 列示对隐式类型参数标记用法的限制。

表 1. 对参数标记用法的限制
隐式类型参数标记位置	数据类型
表达式：单独在选择列表中	错误
表达式：算术运算符的两个操作数	错误
谓词：IN 谓词的左端操作数	错误
谓词：关系运算符的两个操作数	错误
函数：聚集函数的操作数	错误

示例

您可以使用标准接口（例如，CLI/ODBC、JDBC 和 ADO.NET）访问数据库。以下代码段显示如何将预编译语句与每个数据访问 API 的参数标记配合使用。

考虑表 t1 的以下表模式，其中列 c1 是表 t1 的主键。

表 2. 示例表模式
列名	Db2®	是否可空
c1	INTEGER	false
c2	SMALLINT	是
c3	CHAR(20)	是
c4	VARCHAR(20)	是
c5	DECIMAL(8,2)	是
c6	日期	是
c7	时间	是
c8	TIMESTAMP	是
c9	BLOB(30)	是

以下示例演示如何使用预编译语句向表 t1 插入一行。

CLI 示例

void parameterExample1(void) 
{ 
   SQLHENV henv; 
   SQLHDBC hdbc; 
   SQLHSTMT hstmt; 
   SQLRETURN rc; 
   TCHAR server[] = _T("C:\\mysample\\"); 
   TCHAR uid[] = _T("db2e"); 
   TCHAR pwd[] = _T("db2e"); 
   long p1 = 10; 
   short p2 = 100; 
   TCHAR p3[100]; 
   TCHAR p4[100]; 
   TCHAR p5[100]; 
   TCHAR p6[100]; 
   TCHAR p7[100]; 
   TCHAR p8[100]; 
   char  p9[100]; 
   long len = 0; 

   _tcscpy(p3, _T("data1")); 
   _tcscpy(p4, _T("data2")); 
   _tcscpy(p5, _T("10.12")); 
   _tcscpy(p6, _T("2003-06-30")); 
   _tcscpy(p7, _T("12:12:12")); 
   _tcscpy(p8, _T("2003-06-30-17.54.27.710000")); 

   memset(p9, 0, sizeof(p9)); 
   p9[0] = 'X'; 
   p9[1] = 'Y'; 
   p9[2] = 'Z'; 

   rc = SQLAllocEnv(&henv); 
   // check return code ... 

   rc = SQLAllocConnect(henv, &hdbc); 
   // check return code ... 

   rc = SQLConnect(hdbc, (SQLTCHAR*)server, SQL_NTS,
				(SQLTCHAR*)uid, SQL_NTS, (SQLTCHAR*)pwd, SQL_NTS); 
   // check return code ... 

   rc = SQLAllocStmt(hdbc, &hstmt); 
   // check return code ... 

   // prepare the statement 
   rc = SQLPrepare(hstmt, _T("INSERT INTO t1 VALUES (?,?,?,?,?,?,?,?,?)"), SQL_NTS); 
   // check return code ... 

   // bind input parameters 
   rc = SQLBindParameter(hstmt, (unsigned short)1, SQL_PARAM_INPUT,
				SQL_C_LONG, SQL_INTEGER, 4, 0, &p1, sizeof(p1), &len); 
   // check return code ... 

   rc = SQLBindParameter(hstmt, (unsigned short)2, SQL_PARAM_INPUT, SQL_C_LONG,
					SQL_SMALLINT, 2, 0, &p2, sizeof(p2), &len); 
   // check return code ... 

   len = SQL_NTS; 
   rc = SQLBindParameter(hstmt, (unsigned short)3, SQL_PARAM_INPUT, SQL_C_TCHAR,
					SQL_CHAR, 0, 0, &p3[0], 100, &len); 
   // check return code ... 

   rc = SQLBindParameter(hstmt, (unsigned short)4, SQL_PARAM_INPUT, SQL_C_TCHAR,
					SQL_VARCHAR, 0, 0, &p4[0], 100, &len); 
   // check return code ... 

   rc = SQLBindParameter(hstmt, (unsigned short)5, SQL_PARAM_INPUT, SQL_C_TCHAR,
					SQL_DECIMAL, 8, 2, &p5[0], 100, &len); 
   // check return code ... 

   rc = SQLBindParameter(hstmt, (unsigned short)6, SQL_PARAM_INPUT, SQL_C_TCHAR,
					SQL_TYPE_DATE, 0, 0, &p6[0], 100, &len); 
   // check return code ... 

   rc = SQLBindParameter(hstmt, (unsigned short)7, SQL_PARAM_INPUT, SQL_C_TCHAR,
					SQL_TYPE_TIME, 0, 0, &p7[0], 100, &len); 
   // check return code ... 

   rc = SQLBindParameter(hstmt, (unsigned short)8, SQL_PARAM_INPUT, SQL_C_TCHAR,
					SQL_TYPE_TIMESTAMP, 0, 0, &p8[0], 100, &len); 
   // check return code ... 

   len = 3; 
   rc = SQLBindParameter(hstmt, (unsigned short)9, SQL_PARAM_INPUT, SQL_C_BINARY,
					SQL_BINARY, 0, 0, &p9[0], 100, &len); 
   // check return code ... 

   // execute the prepared statement 
   rc = SQLExecute(hstmt); 
   // check return code ... 

   rc = SQLFreeStmt(hstmt, SQL_DROP); 
   // check return code ... 

   rc = SQLDisconnect(hdbc); 
   // check return code ... 

   rc = SQLFreeConnect(hdbc); 
   // check return code ... 

   rc = SQLFreeEnv(henv); 
   // check return code ...

C 示例

EXEC SQL BEGIN DECLARE SECTION; 
  char hostVarStmt1[50]; 
  short hostVarDeptnumb; 
EXEC SQL END DECLARE SECTION; 

/* prepare the statement with a parameter marker */ 
strcpy(hostVarStmt1, "DELETE FROM org WHERE deptnumb = ?"); 
EXEC SQL PREPARE Stmt1 FROM :hostVarStmt1;

/* execute the statement for hostVarDeptnumb = 15 */ 
hostVarDeptnumb = 15; 
EXEC SQL EXECUTE Stmt1 USING :hostVarDeptnumb;

JDBC 示例

public static void parameterExample1() { 

   String driver = "com.ibm.db2e.jdbc.DB2eDriver"; 
   String url    = "jdbc:db2e:mysample"; 
   Connection conn = null; 
   PreparedStatement pstmt = null; 

   try 
   { 
      Class.forName(driver); 

      conn = DriverManager.getConnection(url); 

      // prepare the statement 
      pstmt = conn.prepareStatement("INSERT INTO t1 VALUES
                                                    (?, ?, ?, ?, ?, ?, ?, ?, ?)");

      // bind the input parameters 
      pstmt.setInt(1, 1); 
      pstmt.setShort(2, (short)2); 
      pstmt.setString(3, "data1"); 
      pstmt.setString(4, "data2"); 
      pstmt.setBigDecimal(5, new java.math.BigDecimal("12.34")); 
      pstmt.setDate(6, new java.sql.Date(System.currentTimeMillis() ) ); 
      pstmt.setTime(7, new java.sql.Time(System.currentTimeMillis() ) ); 
      pstmt.setTimestamp (8, new java.sql.Timestamp(System.currentTimeMillis() ) );
      pstmt.setBytes(9, new byte[] { (byte)'X', (byte)'Y', (byte)'Z' } ); 

      // execute the statement 
      pstmt.execute(); 

      pstmt.close(); 

      conn.close(); 
   } 
   catch (SQLException sqlEx) 
   { 
      while(sqlEx != null) 
      { 
          System.out.println("SQLERROR: \n" + sqlEx.getErrorCode() + 
             ", SQLState: " + sqlEx.getSQLState() + 
             ", Message: " + sqlEx.getMessage() + 
             ", Vendor: " + sqlEx.getErrorCode() ); 
         sqlEx = sqlEx.getNextException(); 
      } 
   } 
   catch (Exception ex) 
   { 
      ex.printStackTrace(); 
   } 
}

ADO.NET 示例 [C#]

public static void ParameterExample1() 
{ 
   DB2eConnection conn = null; 
   DB2eCommand cmd  = null; 
   String connString   = @"database=.\; uid=db2e; pwd=db2e"; 
   int i = 1; 

   try 
   { 
      conn = new DB2eConnection(connString); 

      conn.Open(); 

      cmd = new DB2eCommand("INSERT INTO t1 VALUES 
                                      (?, ?, ?, ?, ?, ?, ?, ?, ?)", conn);

      // prepare the command 
      cmd.Prepare(); 

      // bind the input parameters 
      DB2eParameter p1 = new DB2eParameter("@p1", DB2eType.Integer); 
      p1.Value = ++i; 
      cmd.Parameters.Add(p1); 

      DB2eParameter p2 = new DB2eParameter("@p2", DB2eType.SmallInt); 
      p2.Value = 100; 
      cmd.Parameters.Add(p2); 

      DB2eParameter p3 = new DB2eParameter("@p3", DB2eType.Char); 
      p3.Value = "data1"; 
      cmd.Parameters.Add(p3); 

      DB2eParameter p4 = new DB2eParameter("@p4", DB2eType.VarChar); 
      p4.Value = "data2"; 
      cmd.Parameters.Add(p4); 

      DB2eParameter p5 = new DB2eParameter("@p5", DB2eType.Decimal); 
      p5.Value = 20.25; 
      cmd.Parameters.Add(p5); 

      DB2eParameter p6 = new DB2eParameter("@p6", DB2eType.Date); 
      p6.Value = DateTime.Now; 
      cmd.Parameters.Add(p6); 

      DB2eParameter p7 = new DB2eParameter("@p7", DB2eType.Time); 
      p7.Value = new TimeSpan(23, 23, 23); 
      cmd.Parameters.Add(p7); 

      DB2eParameter p8 = new DB2eParameter("@p8", DB2eType.Timestamp); 
      p8.Value = DateTime.Now; 
      cmd.Parameters.Add(p8); 

      byte []barr = new byte[3]; 
      barr[0] = (byte)'X'; 
      barr[1] = (byte)'Y'; 
      barr[2] = (byte)'Z'; 

      DB2eParameter p9 = new DB2eParameter("@p9", DB2eType.Blob); 
      p9.Value = barr; 
      cmd.Parameters.Add(p9); 

      // execute the prepared command 
      cmd.ExecuteNonQuery(); 
   } 
   catch (DB2eException e1) 
   { 
      for (int i=0; i < e1.Errors.Count; i++) 
      { 
         Console.WriteLine("Error #" + i + "\n" + 
            "Message: " + e1.Errors[i].Message + "\n" + 
            "Native: " + e1.Errors[i].NativeError.ToString() + "\n" + 
            "SQL: " + e1.Errors[i].SQLState + "\n"); 
      } 
   } 
   catch (Exception e2) 
   { 
       Console.WriteLine(e2.Message); 
   } 
   finally 
   { 
      if (conn != null && conn.State != ConnectionState.Closed) 
      { 
            conn.Close(); 
            conn = null; 
      } 
   } 
}