mirror of
https://gitlab.com/freepascal.org/fpc/source.git
synced 2025-05-01 20:13:43 +02:00
292 lines
11 KiB
ObjectPascal
292 lines
11 KiB
ObjectPascal
unit mysql_com;
|
|
|
|
{$undef use_mysql_321} { if undefined, use mysql 3.23 interface }
|
|
|
|
{ updated to match version 3.23 header files of mysql by Bernhard Steffen
|
|
(bernhard.steffen@gmx.net)
|
|
}
|
|
|
|
interface
|
|
|
|
uses
|
|
mysql_version;
|
|
|
|
{$ifdef win32}
|
|
Const mysqllib = 'libmysql';
|
|
{$else}
|
|
Const mysqllib = 'mysqlclient';
|
|
{$endif}
|
|
|
|
{$ifndef win32}
|
|
{$linklib c}
|
|
{$linklib m}
|
|
{$linklib mysqlclient}
|
|
{$endif}
|
|
{$r+,i+,o+}
|
|
|
|
|
|
{
|
|
Common definition between mysql server & client
|
|
}
|
|
|
|
{$packrecords 4}
|
|
{ Extra types introduced for pascal }
|
|
Type
|
|
pbyte = ^byte;
|
|
pcardinal = ^cardinal;
|
|
Socket = longint;
|
|
my_bool = byte;
|
|
|
|
Const
|
|
NAME_LEN = 64 ; { Field/table name length }
|
|
LOCAL_HOST : pchar = 'localhost' ;
|
|
|
|
MYSQL_PORT = 3306; { Alloced by ISI for MySQL }
|
|
MYSQL_UNIX_ADDR : pchar = '/tmp/mysql.sock';
|
|
|
|
Type
|
|
enum_server_command = ( COM_SLEEP,COM_QUIT,COM_INIT_DB,COM_QUERY,
|
|
COM_FIELD_LIST,COM_CREATE_DB,COM_DROP_DB,COM_REFRESH,
|
|
COM_SHUTDOWN,COM_STATISTICS,
|
|
COM_PROCESS_INFO,COM_CONNECT,COM_PROCESS_KILL,
|
|
COM_DEBUG);
|
|
|
|
Const
|
|
NOT_NULL_FLAG = 1; { Field can't be NULL }
|
|
PRI_KEY_FLAG = 2; { Field is part of a primary key }
|
|
UNIQUE_KEY_FLAG = 4; { Field is part of a unique key }
|
|
MULTIPLE_KEY_FLAG = 8; { Field is part of a key }
|
|
BLOB_FLAG = 16; { Field is a blob }
|
|
UNSIGNED_FLAG = 32; { Field is unsigned }
|
|
ZEROFILL_FLAG = 64; { Field is zerofill }
|
|
BINARY_FLAG = 128;
|
|
{ The following are only sent to new clients }
|
|
ENUM_FLAG = 256; { field is an enum }
|
|
AUTO_INCREMENT_FLAG = 512; { field is a autoincrement field }
|
|
TIMESTAMP_FLAG = 1024; { Field is a timestamp }
|
|
PART_KEY_FLAG = 16384; { Intern; Part of some key }
|
|
GROUP_FLAG = 32768; { Intern group field }
|
|
{$ifndef use_mysql_321}
|
|
UNIQUE_FLAG = 65536; { Intern: Used by sql_yacc }
|
|
{$endif}
|
|
|
|
REFRESH_GRANT = 1; { Refresh grant tables }
|
|
REFRESH_LOG = 2; { Start on new log file }
|
|
REFRESH_TABLES = 4; { close all tables }
|
|
{$ifndef use_mysql_321}
|
|
REFRESH_HOSTS = 8; { Flush host cache }
|
|
REFRESH_STATUS = 16; { Flush status variables }
|
|
REFRESH_THREADS = 32; { Flush status variables }
|
|
REFRESH_SLAVE = 64; { Reset master info and restart slave
|
|
thread }
|
|
REFRESH_MASTER = 128; { Remove all bin logs in the index
|
|
and truncate the index }
|
|
{$endif}
|
|
|
|
{$ifndef use_mysql_321}
|
|
{ The following can't be set with mysql_refresh() }
|
|
REFRESH_READ_LOCK = 16384; { Lock tables for read }
|
|
REFRESH_FAST = 32768; { Intern flag }
|
|
{$endif}
|
|
|
|
CLIENT_LONG_PASSWORD = 1; { new more secure passwords }
|
|
CLIENT_FOUND_ROWS = 2; { Found instead of affected rows }
|
|
CLIENT_LONG_FLAG = 4; { Get all column flags }
|
|
{$ifndef use_mysql_321}
|
|
CLIENT_CONNECT_WITH_DB = 8; { One can specify db on connect }
|
|
CLIENT_NO_SCHEMA = 16; { Don't allow database.table.column }
|
|
CLIENT_COMPRESS = 32; { Can use compression protocol }
|
|
CLIENT_ODBC = 64; { Odbc client }
|
|
CLIENT_LOCAL_FILES = 128; { Can use LOAD DATA LOCAL }
|
|
CLIENT_IGNORE_SPACE = 256; { Ignore spaces before '(' }
|
|
CLIENT_CHANGE_USER = 512; { Support the mysql_change_user() }
|
|
CLIENT_INTERACTIVE = 1024; { This is an interactive client }
|
|
CLIENT_SSL = 2048; { Switch to SSL after handshake }
|
|
CLIENT_IGNORE_SIGPIPE = 4096; { IGNORE sigpipes }
|
|
CLIENT_TRANSACTIONS = 8192; { Client knows about transactions }
|
|
|
|
SERVER_STATUS_IN_TRANS = 1; { Transaction has started }
|
|
SERVER_STATUS_AUTOCOMMIT = 2; { Server in auto_commit mode }
|
|
{$endif}
|
|
|
|
MYSQL_ERRMSG_SIZE = 200;
|
|
NET_READ_TIMEOUT = 30; { Timeout on read }
|
|
NET_WRITE_TIMEOUT = 60; { Timeout on write }
|
|
NET_WAIT_TIMEOUT = 8*60*60; { Wait for new query }
|
|
|
|
Type
|
|
pst_used_mem = ^st_used_mem;
|
|
st_used_mem = record { struct for once_alloc }
|
|
next : pst_used_mem; { Next block in use }
|
|
left : cardinal; { memory left in block }
|
|
size : cardinal; { size of block }
|
|
end;
|
|
|
|
TUSED_MEM = st_used_mem;
|
|
PUSED_MEM = ^TUSED_MEM;
|
|
|
|
TError_handler = Procedure;
|
|
|
|
st_mem_root = record
|
|
free : PUSED_MEM;
|
|
used : PUSED_MEM;
|
|
{$ifndef use_mysql_321}
|
|
pre_alloc: PUSED_MEM;
|
|
{$endif use_mysql_321}
|
|
min_malloc : cardinal;
|
|
block_size : cardinal;
|
|
error_handler : TERROR_Handler;
|
|
end;
|
|
TMEM_ROOT = st_mem_root;
|
|
PMEM_ROOT = ^TMEM_ROOT;
|
|
|
|
Type
|
|
net_type = (NET_TYPE_TCPIP, NET_TYPE_SOCKET, NETTYPE_NAMEDPIPE);
|
|
st_net = record
|
|
nettype : net_type; //DT
|
|
fd : Socket;
|
|
fcntl : Longint;
|
|
buff,buff_end,write_pos,read_pos : Pchar;//DT
|
|
last_error : array [0..MYSQL_ERRMSG_SIZE-1] of char;
|
|
last_errno,max_packet,timeout,pkt_nr : Cardinal;
|
|
error,return_errno : my_bool;
|
|
compress : my_bool; //DT
|
|
{$ifndef use_mysql_321}
|
|
no_send_ok : my_bool;
|
|
{$endif}
|
|
remain_in_buf,r_length, buf_length, where_b : cardinal; //DT
|
|
{$ifndef use_mysql_321}
|
|
return_status : ^Cardinal;
|
|
reading_or_writing : my_bool;
|
|
{$else}
|
|
more : my_bool;//DT
|
|
{$endif}
|
|
save_char : char; //DT
|
|
end;
|
|
TNET = st_net;
|
|
PNET = ^TNET;
|
|
|
|
Const
|
|
packet_error : longint = -1;
|
|
|
|
Type
|
|
enum_field_types = ( FIELD_TYPE_DECIMAL, FIELD_TYPE_TINY,
|
|
FIELD_TYPE_SHORT, FIELD_TYPE_LONG,
|
|
FIELD_TYPE_FLOAT, FIELD_TYPE_DOUBLE,
|
|
FIELD_TYPE_NULL, FIELD_TYPE_TIMESTAMP,
|
|
FIELD_TYPE_LONGLONG,FIELD_TYPE_INT24,
|
|
FIELD_TYPE_DATE, FIELD_TYPE_TIME,
|
|
FIELD_TYPE_DATETIME,
|
|
{$ifndef use_mysql_321}
|
|
FIELD_TYPE_YEAR,
|
|
FIELD_TYPE_NEWDATE,
|
|
{$endif}
|
|
FIELD_TYPE_ENUM := 247,
|
|
FIELD_TYPE_SET := 248,
|
|
FIELD_TYPE_TINY_BLOB := 249,
|
|
FIELD_TYPE_MEDIUM_BLOB := 250,
|
|
FIELD_TYPE_LONG_BLOB :=251,
|
|
FIELD_TYPE_BLOB :=252,
|
|
FIELD_TYPE_VAR_STRING :=253,
|
|
FIELD_TYPE_STRING:=254);
|
|
|
|
Const
|
|
FIELD_TYPE_CHAR = FIELD_TYPE_TINY; { For compability }
|
|
FIELD_TYPE_INTERVAL = FIELD_TYPE_ENUM; { For compability }
|
|
|
|
Procedure sql_free (root : PMEM_ROOT);stdcall;
|
|
Procedure init_alloc_root (root: PMEM_ROOT;block_size : Cardinal);stdcall;
|
|
Function sql_alloc_first_block(root : PMEM_ROOT) : my_bool;stdcall;
|
|
Function sql_alloc_root(mem_root : PMEM_ROOT;len : Cardinal) : longint;stdcall;
|
|
Function sql_strdup_root(root : PMEM_ROOT;st : pchar) : pchar;stdcall;
|
|
Function sql_memdup_root(root: PMEM_ROOT;st : pchar; len : Cardinal): longint;stdcall;
|
|
|
|
{
|
|
extern unsigned long max_allowed_packet;
|
|
extern unsigned long net_buffer_length;
|
|
}
|
|
|
|
{
|
|
#define net_new_transaction(net) ((net)->pkt_nr=0)
|
|
}
|
|
|
|
Function my_net_init(net :PNET; fd : Socket) : Longint;stdcall;
|
|
procedure net_end(net : PNET);stdcall;
|
|
Procedure net_clear(net : PNET);stdcall;
|
|
Function net_flush(net : PNET) : longint;stdcall;
|
|
Function my_net_write(net : PNET;packet : pbyte;len : cardinal) : longint;stdcall;
|
|
Function net_write_command(net : PNET; command : char;packet : pbyte;len : cardinal) : longint;stdcall;
|
|
Function net_real_write(net : PNET;packet : pbyte; len : Cardinal) : longint;stdcall;
|
|
Function my_net_read(net : PNET) : Cardinal;stdcall;
|
|
|
|
Type
|
|
TRand_struct = record
|
|
seed,seed2,max_value : Cardinal;
|
|
max_value_dbl : double;
|
|
end;
|
|
PRand_struct = ^TRand_struct;
|
|
|
|
{ The following is for user defined functions }
|
|
|
|
Item_result = (STRING_RESULT,REAL_RESULT,INT_RESULT);
|
|
|
|
st_udf_args = record
|
|
arg_count : cardinal; { Number of arguments }
|
|
arg_type : ^Item_result; { Pointer to item_results }
|
|
args : ppchar; { Pointer to argument }
|
|
lengths : PCardinal; { Length of string arguments }
|
|
end;
|
|
TUDF_ARGS = st_udf_args;
|
|
PUDPF_ARGS = ^TUDF_ARGS;
|
|
|
|
{ This holds information about the result }
|
|
|
|
st_udf_init = record
|
|
maybe_null : my_bool; { 1 if function can return NULL }
|
|
decimals : cardinal; { for real functions }
|
|
max_length : Cardinal; { For string functions }
|
|
ptr : PChar; { free pointer for function data }
|
|
end;
|
|
TUDF_INIT = st_udf_init;
|
|
PUDF_INIT = TUDF_INIT;
|
|
|
|
{ Prototypes to password functions }
|
|
|
|
procedure randominit(rand : Prand_struct; seed1,seed2 : Cardinal);stdcall;
|
|
Function rnd(rand : Prand_struct) : double;stdcall;
|
|
procedure make_scrambled_password(toarg, passwd : Pchar);stdcall;
|
|
procedure get_salt_from_password(res : pcardinal; password : pchar);stdcall;
|
|
procedure scramble(toarg,message,password : pchar; old_ver : my_bool);stdcall;
|
|
function check_scramble(scramble,message : pchar; salt : cardinal;old_ver:my_bool) : my_bool;stdcall;
|
|
function get_tty_password(opt_message: pchar) : pchar;stdcall;
|
|
|
|
{
|
|
#define NULL_LENGTH ((unsigned long) ~0) { For net_store_length }
|
|
}
|
|
|
|
implementation
|
|
|
|
Procedure sql_free (root : PMEM_ROOT);stdcall;external;
|
|
Procedure init_alloc_root (root: PMEM_ROOT;block_size : Cardinal);stdcall;external;
|
|
Function sql_alloc_first_block(root : PMEM_ROOT) : my_bool;stdcall;external;
|
|
Function sql_alloc_root(mem_root : PMEM_ROOT;len : Cardinal) : longint;stdcall;external;
|
|
Function sql_strdup_root(root : PMEM_ROOT;st : pchar) : pchar;stdcall;external;
|
|
Function sql_memdup_root(root: PMEM_ROOT;st : pchar; len : Cardinal) : longint;stdcall;external;
|
|
Function my_net_init(net :PNET; fd : Socket) : Longint;stdcall;external;
|
|
procedure net_end(net : PNET);stdcall;external;
|
|
Procedure net_clear(net : PNET);stdcall;external;
|
|
Function net_flush(net : PNET) : longint;stdcall;external;
|
|
Function my_net_write(net : PNET;packet : pbyte;len : cardinal) : longint;stdcall;external;
|
|
Function net_write_command(net : PNET; command : char;packet : pbyte;len : cardinal) : longint;stdcall;external;
|
|
Function net_real_write(net : PNET;packet : pbyte; len : Cardinal) : longint;stdcall;external;
|
|
Function my_net_read(net : PNET) : Cardinal;stdcall;external;
|
|
procedure randominit(rand : Prand_struct; seed1,seed2 : Cardinal);stdcall;external;
|
|
Function rnd(rand : Prand_struct) : double;stdcall;external;
|
|
procedure make_scrambled_password(toarg, passwd : Pchar);stdcall;external;
|
|
procedure get_salt_from_password(res : pcardinal; password : pchar);stdcall;external;
|
|
procedure scramble(toarg,message,password : pchar; old_ver : my_bool);stdcall;external;
|
|
function check_scramble(scramble,message : pchar; salt : cardinal;old_ver:my_bool) : my_bool;stdcall;external;
|
|
function get_tty_password(opt_message: pchar) : pchar;stdcall;external;
|
|
|
|
end.
|