Zeoslib Portal

Code: Select all

  MYSQL_BIND = record
    length:           PLongInt;
    is_null:          PByte;
    buffer:           PChar;
    buffer_type:      Cardinal;
    buffer_length:    LongInt;
    inter_buffer:     PByte;
    offset:           LongInt;
    internal_length:  LongInt;
    param_number:     Cardinal;
    long_data_used:   Byte;
    binary_data:      Byte;
    null_field:       Byte;
    internal_is_null: Byte;
    store_param_func: procedure(_net: NET; param: PMYSQL_BIND);
    fetch_result:     procedure(param: PMYSQL_BIND; row: PMYSQL_ROW);
  end;

Code: Select all

typedef struct st_mysql_bind
{
  unsigned long	*length;          /* output length pointer */
  my_bool       *is_null;	  /* Pointer to null indicator */
  void		*buffer;	  /* buffer to get/put data */
  /* set this if you want to track data truncations happened during fetch */
  my_bool       *error;
  enum enum_field_types buffer_type;	/* buffer type */
  /* output buffer length, must be set when fetching str/binary */
  unsigned long buffer_length;
  unsigned char *row_ptr;         /* for the current data position */
  unsigned long offset;           /* offset position for char/binary fetch */
  unsigned long	length_value;     /* Used if length is 0 */
  unsigned int	param_number;	  /* For null count and error messages */
  unsigned int  pack_length;	  /* Internal length for packed data */
  my_bool       error_value;      /* used if error is 0 */
  my_bool       is_unsigned;      /* set if integer type is unsigned */
  my_bool	long_data_used;	  /* If used with mysql_send_long_data */
  my_bool	is_null_value;    /* Used if is_null is 0 */
  void (*store_param_func)(NET *net, struct st_mysql_bind *param);
  void (*fetch_result)(struct st_mysql_bind *, MYSQL_FIELD *,
                       unsigned char **row);
  void (*skip_result)(struct st_mysql_bind *, MYSQL_FIELD *,
		      unsigned char **row);
} MYSQL_BIND;

Code: Select all

  MYSQL_BIND = record
    length:           PLongInt;
    is_null:          PByte;
    buffer:           PChar;
    error :           PByte; // new
    buffer_type:      Cardinal;
    buffer_length:    LongInt;
    inter_buffer:     PByte;
    offset:           LongInt;
    internal_length:  LongInt;
    param_number:     Cardinal;
    pack_length :     Cardinal; // new
    error_value :     Byte; // new
    is_unsigned:   Byte;
    long_data_used:      Byte;
    null_field:       Byte;
    store_param_func: procedure(_net: NET; param: PMYSQL_BIND); cdecl;
    fetch_result:     procedure(param: PMYSQL_BIND; fld : PMYSQL_FIELD; row: PMYSQL_ROW); cdecl;
    skip_result :     procedure(param: PMYSQL_BIND; fld : PMYSQL_FIELD; row: PMYSQL_ROW); cdecl;
  end;

Code: Select all

program dbc;

{$APPTYPE CONSOLE}

uses
  SysUtils,
  Windows,
  ZClasses,
  ZDbcIntfs,
  ZCompatibility,
  ZDbcMySql,
  ZPlainMySQLDriver,
  ZPlainMySQL5;

var
  conn : IZConnection;
  stmt : IZStatement;
  // mysql specific
  drv : IZMySQLPlainDriver;
  conn_handle : Pointer;
  pstmt_handle : Pointer;
  binds : array [0..1] of MYSQL_BIND;
  buf : array [0..1023] of char;
  str_param_length : Integer;
  // end mysql specific
  i : Integer;
  query : string;
begin
try
  conn := DriverManager.GetConnection('zdbc:mysql-5://localhost/db?UID=uid;PWD=pwd');
  stmt := conn.CreateStatement;
  stmt.ExecuteUpdate('DROP TABLE IF EXISTS t');
  stmt.ExecuteUpdate('CREATE TABLE t ( x INTEGER, y VARCHAR(50) ) ENGINE=MEMORY');
  stmt.Close;
  stmt := nil;

  // get mysql specific bits
  drv := (conn as IZMySQLConnection).GetPlainDriver;
  conn_handle := (conn as IZMySQLConnection).GetConnectionHandle;

  pstmt_handle := drv.InitializePrepStmt(conn_handle);
  ZeroMemory(@binds, SizeOf(binds));
  query := 'INSERT INTO t (y, x) VALUES (?, ?)';
  drv.PrepareStmt(pstmt_handle, PAnsiChar(query), Length(query));
  binds[1].buffer_type := FIELD_TYPE_LONG;
  binds[1].buffer := PAnsiChar(@i);
  binds[1].is_null := nil;
  binds[1].length := nil;
  binds[0].buffer_type := FIELD_TYPE_STRING;
  binds[0].buffer := buf;
  binds[0].buffer_length := 1024;
  binds[0].is_null := nil;
  binds[0].length := @str_param_length;
  writeln('markers: ', drv.GetPreparedBindMarkers(pstmt_handle));
  drv.BindParameters(pstmt_handle, @binds);
  for i := 1 to 3 do begin
    buf := 'xyzzy';
    str_param_length := 5;
    drv.ExecuteStmt(pstmt_handle);
  end;
  drv.ClosePrepStmt(pstmt_handle);

  conn.Close;
  conn := nil;
  writeln('press any key');
  readln;
except
on e: Exception do begin writeln(e.message); readln; end;
end;
end.