开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数值算法/人工智能 > 生物技术 > 查看源码
tds.h
资源名称：ncbi_cxx_win--Jul_08_2004.zip　[点击查看]
上传用户：yhdzpy8989
上传日期：2007-06-13
资源大小：13604k
文件大小：24k
源码类别：

生物技术

开发平台：

C/C++

tds.h：源码内容
  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: tds.h,v $
  4.  * PRODUCTION Revision 1000.1  2003/11/17 22:11:37  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [ORIGINAL] Dev-tree R1.3
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  10. /* FreeTDS - Library of routines accessing Sybase and Microsoft databases
  11.  * Copyright (C) 1998-1999  Brian Bruns
  12.  *
  13.  * This library is free software; you can redistribute it and/or
  14.  * modify it under the terms of the GNU Library General Public
  15.  * License as published by the Free Software Foundation; either
  16.  * version 2 of the License, or (at your option) any later version.
  17.  *
  18.  * This library is distributed in the hope that it will be useful,
  19.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  21.  * Library General Public License for more details.
  22.  *
  23.  * You should have received a copy of the GNU Library General Public
  24.  * License along with this library; if not, write to the
  25.  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  26.  * Boston, MA 02111-1307, USA.
  27.  */
  29. #ifndef _tds_h_
  30. #define _tds_h_
  32. static char rcsid_tds_h[]=
  33.  "$Id: tds.h,v 1000.1 2003/11/17 22:11:37 gouriano Exp $";
  34. static void *no_unused_tds_h_warn[]={rcsid_tds_h, no_unused_tds_h_warn};
  36. #include <tds_config.h>
  38. #ifndef WIN32
  39. #include <sys/types.h>
  40. #include <sys/socket.h>
  41. #include <netinet/in.h>
  42. #include <arpa/inet.h>
  43. #include <netdb.h>
  44. #include <sys/signal.h>
  45. #include <sys/wait.h>
  46. #endif 
  48. #ifdef WIN32
  49. #include <windows.h>
  50. #include <stdio.h>
  51. #endif
  53. #ifdef __INCvxWorksh
  54. #include <signal.h>
  55. #include <ioLib.h> /* for FIONBIO */
  56. #else
  57. #include <errno.h>
  58. #include <stdio.h>
  59. #include <ctype.h>
  60. #include <string.h>
  61. #include <stdlib.h>
  62. #include <time.h>
  63. #ifdef HAVE_MALLOC_H
  64. #include <malloc.h>
  65. #endif
  66. #include <sys/time.h>
  67. #endif
  69. #ifndef WIN32
  70. #include <unistd.h>
  71. #endif
  73. #include "tdsver.h"
  75. #ifdef __cplusplus
  76. extern "C" {
  77. #endif 
  79. /* 
  80. ** this is where platform specific changes need to be made.
  81. ** I've tried to change all references to data that goes to 
  82. ** or comes off the wire to use these typedefs.  I've probably 
  83. ** missed a bunch, but the idea is we can do an ifdef here 
  84. ** to set the appropriately sized native type.
  85. **
  86. ** If you have problems on 64-bit machines and the code is 
  87. ** using a native datatype, please change the code to use
  88. ** these. (In the TDS layer only, the API layers have their
  89. ** own typedefs which equate to these).
  90. */
  91. typedef char TDS_CHAR;      /*  8 bit char     */
  92. typedef unsigned char TDS_UCHAR;     /*  8 bit uchar    */
  93. typedef unsigned char TDS_TINYINT;   /*  8 bit int      */
  94. typedef short            TDS_SMALLINT;  /* 16 bit int      */
  95. typedef unsigned short   TDS_USMALLINT; /* 16 bit unsigned */
  96. typedef int                 TDS_INT;       /* 32 bit int      */
  97. typedef unsigned int        TDS_UINT;      /* 32 bit unsigned */
  98. typedef float                TDS_REAL;      /* 32 bit float    */
  99. typedef double               TDS_FLOAT;     /* 64 bit float    */
  100. typedef long long TDS_INT8;      /* 64 bit integer  */
  101. typedef unsigned long long TDS_UINT8;      /* 64 bit integer  */
  103. typedef struct tdsnumeric
  104. {
  105.         unsigned char         precision;
  106.         unsigned char         scale;
  107.         unsigned char         array[17];
  108. } TDS_NUMERIC;
  110. typedef struct tdsoldmoney
  111. {
  112. TDS_INT         mnyhigh;
  113. TDS_INT         mnylow;
  114. } TDS_OLD_MONEY;
  116. typedef union tdsmoney
  117. { TDS_OLD_MONEY tdsoldmoney;
  118.         TDS_INT8        mny;
  119. } TDS_MONEY;
  121. typedef struct tdsmoney4
  122. {
  123.         TDS_INT          mny4;
  124. } TDS_MONEY4;
  126. typedef struct tdsdatetime
  127. {
  128. TDS_INT dtdays;
  129. TDS_INT dttime;
  130. } TDS_DATETIME;
  132. typedef struct tdsdatetime4
  133. {
  134. TDS_USMALLINT days;
  135. TDS_USMALLINT minutes;
  136. } TDS_DATETIME4;
  138. typedef struct tdsvarbinary
  139. {
  140. TDS_INT len;
  141. TDS_CHAR array[256];
  142. } TDS_VARBINARY;
  143. typedef struct tdsvarchar
  144. {
  145. TDS_INT len;
  146. TDS_CHAR array[256];
  147. } TDS_VARCHAR;
  149. typedef struct tdsunique
  150. {
  151.     TDS_UINT      Data1;
  152.     TDS_USMALLINT Data2;
  153.     TDS_USMALLINT Data3;
  154.     TDS_UCHAR     Data4[8];
  155. } TDS_UNIQUE;
  157. typedef struct tdsdaterec
  158. {
  159. TDS_INT   year;
  160. TDS_INT   month;
  161. TDS_INT   day;
  162. TDS_INT   dayofyear;
  163. TDS_INT   weekday;
  164. TDS_INT   hour;
  165. TDS_INT   minute;
  166. TDS_INT   second;
  167. TDS_INT   millisecond;
  168. TDS_INT   tzone;
  169. } TDSDATEREC;
  171. #define TDS_NO_MORE_ROWS     -2
  172. #define TDS_SUCCEED          1
  173. #define TDS_FAIL             0
  174. #define TDS_NO_MORE_RESULTS  2
  175. /*
  176. ** TDS_ERROR indicates a successful processing, but an TDS_ERR_TOKEN or 
  177. ** TDS_EED_TOKEN error was encountered, whereas TDS_FAIL indicates an
  178. ** unrecoverable failure.
  179. */
  180. #define TDS_ERROR            3  
  181. #define TDS_DONT_RETURN      42
  183. #define TDS5_DYN_TOKEN      231  /* 0xE7    TDS 5.0 only              */
  184. #define TDS5_DYNRES_TOKEN   236  /* 0xEC    TDS 5.0 only              */
  185. #define TDS5_DYN3_TOKEN     215  /* 0xD7    TDS 5.0 only              */
  186. #define TDS_LANG_TOKEN       33  /* 0x21    TDS 5.0 only              */
  187. #define TDS_CLOSE_TOKEN     113  /* 0x71    TDS 5.0 only? ct_close()  */
  188. #define TDS_RET_STAT_TOKEN  121  /* 0x79                              */
  189. #define TDS_124_TOKEN       124  /* 0x7C    TDS 4.2 only - TDS_PROCID */
  190. #define TDS7_RESULT_TOKEN   129  /* 0x81    TDS 7.0 only              */
  191. #define TDS_COL_NAME_TOKEN  160  /* 0xA0    TDS 4.2 only              */
  192. #define TDS_COL_INFO_TOKEN  161  /* 0xA1    TDS 4.2 only - TDS_COLFMT */
  193. /*#define  TDS_TABNAME   164 */
  194. #ifdef NCBI_FTDS
  195. #define  TDS_COL_INFO_TOKEN2   165 /* 0xA5                            */
  196. #endif
  197. #define TDS_167_TOKEN       167  /* 0xA7                              */
  198. #define TDS_168_TOKEN       168  /* 0xA8                              */
  199. #define TDS_ORDER_BY_TOKEN  169  /* 0xA9    TDS_ORDER                 */
  200. #define TDS_ERR_TOKEN       170  /* 0xAA                              */
  201. #define TDS_MSG_TOKEN       171  /* 0xAB                              */
  202. #define TDS_PARAM_TOKEN     172  /* 0xAC    RETURNVALUE?              */
  203. #define TDS_LOGIN_ACK_TOKEN 173  /* 0xAD                              */
  204. #define TDS_174_TOKEN       174  /* 0xAE    TDS_CONTROL               */
  205. #define TDS_ROW_TOKEN       209  /* 0xD1                              */
  206. #define TDS_CMP_ROW_TOKEN   211  /* 0xD3                              */
  207. #define TDS_CAP_TOKEN       226  /* 0xE2                              */
  208. #define TDS_ENV_CHG_TOKEN   227  /* 0xE3                              */
  209. #define TDS_EED_TOKEN       229  /* 0xE5                              */
  210. #define TDS_AUTH_TOKEN      237  /* 0xED                              */
  211. #define TDS_RESULT_TOKEN    238  /* 0xEE                              */
  212. #define TDS_DONE_TOKEN      253  /* 0xFD    TDS_DONE                  */
  213. #define TDS_DONEPROC_TOKEN  254  /* 0xFE    TDS_DONEPROC              */
  214. #define TDS_DONEINPROC_TOKEN 255  /* 0xFF    TDS_DONEINPROC            */
  216. /* states for tds_process_messages() */
  217. #define PROCESS_ROWS    0
  218. #define PROCESS_RESULTS 1
  219. #define CANCEL_PROCESS  2
  220. #define GOTO_1ST_ROW    3
  221. #define LOGIN           4
  223. /* environment type field */
  224. #define TDS_ENV_DATABASE  1
  225. #define TDS_ENV_CHARSET   3
  226. #define TDS_ENV_BLOCKSIZE 4
  228. /* 
  229. <rant> Sybase does an awful job of this stuff, non null ints of size 1 2 
  230. and 4 have there own codes but nullable ints are lumped into INTN
  231. sheesh! </rant>
  232. */
  233. #define SYBCHAR      47   /* 0x2F */
  234. #define SYBVARCHAR   39   /* 0x27 */
  235. #define SYBINTN      38   /* 0x26 */
  236. #define SYBINT1      48   /* 0x30 */
  237. #define SYBINT2      52   /* 0x34 */
  238. #define SYBINT4      56   /* 0x38 */
  239. #define SYBINT8     127   /* 0x7F */
  240. #define SYBFLT8      62   /* 0x3E */
  241. #define SYBDATETIME  61   /* 0x3D */
  242. #define SYBBIT       50   /* 0x32 */
  243. #define SYBTEXT      35   /* 0x23 */
  244. #define SYBNTEXT     99   /* 0x63 */
  245. #define SYBIMAGE     34   /* 0x22 */
  246. #define SYBMONEY4    122  /* 0x7A */
  247. #define SYBMONEY     60   /* 0x3C */
  248. #define SYBDATETIME4 58   /* 0x3A */
  249. #define SYBREAL      59   /* 0x3B */
  250. #define SYBBINARY    45   /* 0x2D */
  251. #define SYBVOID      31   /* 0x1F */
  252. #define SYBVARBINARY 37   /* 0x25 */
  253. #define SYBNVARCHAR  103  /* 0x67 */
  254. #define SYBBITN      104  /* 0x68 */
  255. #define SYBNUMERIC   108  /* 0x6C */
  256. #define SYBDECIMAL   106  /* 0x6A */
  257. #define SYBFLTN      109  /* 0x6D */
  258. #define SYBMONEYN    110  /* 0x6E */
  259. #define SYBDATETIMN  111  /* 0x6F */
  260. #define XSYBCHAR     175  /* 0xAF */
  261. #define XSYBVARCHAR  167  /* 0xA7 */
  262. #define XSYBNVARCHAR 231  /* 0xE7 */
  263. #define XSYBNCHAR    239  /* 0xEF */
  264. #define XSYBVARBINARY 165  /* 0xA5 */
  265. #define XSYBBINARY    173  /* 0xAD */
  267. #define SYBUNIQUE    36    /* 0x24 */
  268. #define SYBVARIANT   0x62
  270. #define TDS_ZERO_FREE(x) {free((x)); (x) = NULL;}
  272. #define TDS_BYTE_SWAP16(value)                 
  273.          (((((unsigned short)value)<<8) & 0xFF00)   | 
  274.           ((((unsigned short)value)>>8) & 0x00FF))
  276. #define TDS_BYTE_SWAP32(value)                     
  277.          (((((unsigned long)value)<<24) & 0xFF000000)  | 
  278.           ((((unsigned long)value)<< 8) & 0x00FF0000)  | 
  279.           ((((unsigned long)value)>> 8) & 0x0000FF00)  | 
  280.           ((((unsigned long)value)>>24) & 0x000000FF))
  282. #define is_end_token(x) (x==TDS_DONE_TOKEN    || 
  283. x==TDS_DONEPROC_TOKEN    || 
  284. x==TDS_DONEINPROC_TOKEN)
  286. #define is_hard_end_token(x) (x==TDS_DONE_TOKEN    || 
  287. x==TDS_DONEPROC_TOKEN)
  289. #define is_msg_token(x) (x==TDS_MSG_TOKEN    || 
  290. x==TDS_ERR_TOKEN    || 
  291. x==TDS_EED_TOKEN)
  293. #define is_result_token(x) (x==TDS_RESULT_TOKEN    || 
  294. x==TDS7_RESULT_TOKEN    || 
  295. x==TDS_COL_INFO_TOKEN    || 
  296. x==TDS_COL_NAME_TOKEN)
  298. /* FIX ME -- not a complete list */
  299. #define is_fixed_type(x) (x==SYBINT1    || 
  300. x==SYBINT2      || 
  301. x==SYBINT4      || 
  302. x==SYBINT8      || 
  303. x==SYBREAL  || 
  304. x==SYBFLT8      || 
  305. x==SYBDATETIME  || 
  306. x==SYBDATETIME4 || 
  307. x==SYBBIT       || 
  308. x==SYBMONEY     || 
  309. x==SYBMONEY4    || 
  310. x==SYBUNIQUE)
  311. #define is_nullable_type(x) (x==SYBINTN || 
  312. x==SYBFLTN      || 
  313. x==SYBDATETIMN  || 
  314. x==SYBVARCHAR   || 
  315. x==SYBVARBINARY || 
  316. x==SYBMONEYN || 
  317. x==SYBTEXT || 
  318. x==SYBNTEXT || 
  319. x==SYBBITN      || 
  320. x==SYBIMAGE)
  321. #define is_blob_type(x) (x==SYBTEXT || x==SYBIMAGE || x==SYBNTEXT)
  322. /* large type means it has a two byte size field */
  323. #define is_large_type(x) (x>128)
  324. #define is_numeric_type(x) (x==SYBNUMERIC || x==SYBDECIMAL)
  325. #define is_unicode(x) (x==XSYBNVARCHAR || x==XSYBNCHAR || x==SYBNTEXT)
  326. #define is_collate_type(x) (x==XSYBVARCHAR || x==XSYBCHAR || x==SYBTEXT || x == XSYBNVARCHAR || x==SYBNTEXT)
  328. #define TDS_MAX_CAPABILITY 18
  329. #define MAXPRECISION  50
  330. #define TDS_MAX_CONN 4096
  331. #define TDS_MAX_DYNID_LEN 30
  333. /* defaults to use if no others are found */
  334. #define TDS_DEF_SERVER "SYBASE"
  335. #define TDS_DEF_BLKSZ 512
  336. #define TDS_DEF_CHARSET "iso_1"
  337. #define TDS_DEF_LANG "us_english"
  338. #if TDS42
  339. #define TDS_DEF_MAJOR 4
  340. #define TDS_DEF_MINOR 2
  341. #define TDS_DEF_PORT 1433
  342. #elif TDS46
  343. #define TDS_DEF_MAJOR 4
  344. #define TDS_DEF_MINOR 6
  345. #define TDS_DEF_PORT 4000
  346. #elif TDS70
  347. #define TDS_DEF_MAJOR 7
  348. #define TDS_DEF_MINOR 0
  349. #define TDS_DEF_PORT 1433
  350. #elif TDS80
  351. #define TDS_DEF_MAJOR 8
  352. #define TDS_DEF_MINOR 0
  353. #define TDS_DEF_PORT 1433
  354. #else
  355. #define TDS_DEF_MAJOR 5
  356. #define TDS_DEF_MINOR 0
  357. #define TDS_DEF_PORT 4000
  358. #endif
  360. /* normalized strings from freetds.conf file */
  361. #define TDS_STR_VERSION  "tds version"
  362. #define TDS_STR_BLKSZ    "initial block size"
  363. #define TDS_STR_SWAPDT   "swap broken dates"
  364. #define TDS_STR_SWAPMNY  "tds version"
  365. #define TDS_STR_TRYSVR   "try server login"
  366. #define TDS_STR_TRYDOM   "try domain login"
  367. #define TDS_STR_DOMAIN   "nt domain"
  368. #define TDS_STR_XDOMAUTH "cross domain auth"
  369. #define TDS_STR_DUMPFILE "dump file"
  370. #define TDS_STR_DEBUGLVL "debug level"
  371. #define TDS_STR_TIMEOUT  "timeout"
  372. #define TDS_STR_CONNTMOUT "connect timeout"
  373. #define TDS_STR_HOSTNAME "hostname"
  374. #define TDS_STR_HOST     "host"
  375. #define TDS_STR_PORT     "port"
  376. #define TDS_STR_TEXTSZ   "text size"
  377. /* for big endian hosts */
  378. #define TDS_STR_EMUL_LE "emulate little endian"
  379. #define TDS_STR_CHARSET "charset"
  380. #define TDS_STR_CLCHARSET "client charset"
  381. #define TDS_STR_LANGUAGE "language"
  382. #define TDS_STR_APPENDMODE "dump file append"
  383. #define TDS_STR_DATEFMT "date format"
  385. #define TDS_MAX_LOGIN_STR_SZ 30
  386. #define TDS_MAX_LIBRARY_STR_SZ 11
  387. typedef struct tds_login {
  388. TDS_CHAR  host_name[TDS_MAX_LOGIN_STR_SZ+1];
  389. TDS_CHAR  user_name[TDS_MAX_LOGIN_STR_SZ+1];
  390. /* FIXME temporary fix, 40 pwd max len */
  391. TDS_CHAR  password[40+1];
  392. TDS_TINYINT bulk_copy; 
  393. TDS_CHAR  app_name[TDS_MAX_LOGIN_STR_SZ+1];
  394. TDS_CHAR  server_name[TDS_MAX_LOGIN_STR_SZ+1];
  395. TDS_TINYINT  major_version; /* TDS version */
  396. TDS_TINYINT  minor_version; /* TDS version */
  397. /* Ct-Library, DB-Library,  TDS-Library or ODBC */
  398. TDS_CHAR  library[TDS_MAX_LIBRARY_STR_SZ+1];
  399. TDS_CHAR language[TDS_MAX_LOGIN_STR_SZ+1]; /* ie us-english */
  400. TDS_TINYINT encrypted; 
  401. TDS_CHAR char_set[TDS_MAX_LOGIN_STR_SZ+1]; /*  ie iso_1 */
  402. TDS_SMALLINT block_size; 
  403. TDS_TINYINT suppress_language;
  404.      TDS_INT connect_timeout;
  405.      TDS_INT query_timeout;
  406.      TDS_INT longquery_timeout;
  407.      void (*longquery_func)(long lHint);
  408.      long longquery_param;
  409. unsigned char capabilities[TDS_MAX_CAPABILITY];
  410. int port;
  411. } TDSLOGIN;
  413. #ifdef NCBI_FTDS
  414. #define NCBI_NUM_SERVERS 8
  415. #endif
  417. typedef struct tds_config_info {
  418.         char *server_name;
  419.         char *host;
  420. #ifdef NCBI_FTDS
  421.         char *ip_addr[NCBI_NUM_SERVERS];
  422.         int port[NCBI_NUM_SERVERS];
  423. #else
  424.         char *ip_addr;
  425.         int port;
  426. #endif
  427.         TDS_SMALLINT minor_version;
  428.         TDS_SMALLINT major_version;
  429.         int block_size;
  430.         char *language;
  431.         char *char_set;
  432.         char *database;
  433.         char *dump_file;
  434.         int broken_dates;
  435.         int broken_money;
  436.         int timeout;
  437.         int connect_timeout;
  438.         char *host_name;
  439.         char *default_domain;
  440.         int try_server_login;
  441.         int try_domain_login;
  442.         int xdomain_auth;
  443.         int debug_level;
  444.         int emul_little_endian;
  445.         int text_size;
  446.         char *app_name;
  447.         char *user_name;
  448.         char *password;
  449.         char *library;
  450.         int bulk_copy;
  451.    int suppress_language;
  452.    int encrypted;
  453.         char *client_charset;
  454. } TDSCONFIGINFO;
  456. typedef struct tds_loc_info {
  457.         char *language;
  458.         char *char_set;
  459.         char *date_fmt;
  460. } TDSLOCINFO;
  462. /* structure for storing data about regular and compute rows */ 
  463. typedef struct tds_column_info {
  464. TDS_SMALLINT column_type;
  465. TDS_SMALLINT column_type_save;
  466. TDS_SMALLINT column_usertype;
  467. TDS_SMALLINT column_flags;
  468. TDS_INT column_size;
  469. TDS_INT column_offset;
  470. TDS_TINYINT column_namelen;
  471. TDS_TINYINT column_varint_size;
  472. #ifdef NCBI_FTDS
  473.     TDS_CHAR column_name[140]; 
  474.     TDS_CHAR full_column_name[140];
  475. #else
  476.    TDS_CHAR column_name[256];
  477. #endif
  478. TDS_SMALLINT column_bindtype;
  479. TDS_SMALLINT column_bindfmt;
  480. TDS_UINT column_bindlen;
  481. TDS_CHAR *column_nullbind;
  482. TDS_CHAR *varaddr;
  483. TDS_CHAR *column_lenbind;
  484. TDS_SMALLINT column_prec;
  485. TDS_SMALLINT column_scale;
  486. TDS_INT column_textsize;
  487. TDS_INT column_textpos;
  488. TDS_INT column_text_sqlgetdatapos;
  489. TDS_CHAR column_textptr[16];
  490. TDS_CHAR column_timestamp[8];
  491. TDS_CHAR *column_textvalue;
  492. TDS_TINYINT column_nullable;
  493. TDS_TINYINT column_writeable;
  494. TDS_TINYINT column_identity;
  495. TDS_TINYINT column_unicodedata;
  496.     TDS_CHAR    collation[5];
  497. TDS_INT cur_row_size; /* size of this column in the current row */
  498. } TDSCOLINFO;
  500. typedef struct tds_result_info {
  501. TDS_SMALLINT  rows_exist;
  502. TDS_INT       row_count;
  503. TDS_INT       row_size;
  504. TDS_SMALLINT  num_cols;
  505. TDS_TINYINT   more_results;
  506. TDSCOLINFO    **columns;
  507. int           null_info_size;
  508. unsigned char *current_row;
  509. } TDSRESULTINFO;
  511. /* values for tds->state */
  512. enum {
  513. TDS_QUERYING,
  514. TDS_PENDING,
  515. TDS_COMPLETED,
  516. TDS_CANCELED,
  517. TDS_DEAD
  518. };
  520. #define TDS_DBG_FUNC    7  
  521. #define TDS_DBG_INFO2   6
  522. #define TDS_DBG_INFO1   5
  523. #define TDS_DBG_NETWORK 4
  524. #define TDS_DBG_WARN    3
  525. #define TDS_DBG_ERROR   2
  526. #define TDS_DBG_SEVERE  1
  528. typedef struct tds_compute_info {
  529.         TDS_SMALLINT num_cols;
  530. TDS_INT row_size;
  531.         TDSCOLINFO **columns;
  532. int           null_info_size;
  533. unsigned char *current_row;
  534. } TDSCOMPUTEINFO;
  536. typedef struct tds_param_info {
  537.         TDS_SMALLINT num_cols;
  538. TDS_INT row_size;
  539.         TDSCOLINFO **columns;
  540. int           null_info_size;
  541. unsigned char *current_row;
  542. } TDSPARAMINFO;
  544. typedef struct tds_input_param {
  545. TDS_SMALLINT column_type;
  546. TDS_CHAR *varaddr;
  547. TDS_UINT column_bindlen;
  548. TDS_CHAR is_null;
  549. } TDSINPUTPARAM;
  551. typedef struct tds_msg_info {
  552.       TDS_SMALLINT priv_msg_type;
  553.       TDS_SMALLINT line_number;
  554.       TDS_UINT msg_number;
  555.       TDS_SMALLINT msg_state;
  556.       TDS_SMALLINT msg_level;
  557.       TDS_CHAR *server;
  558.       TDS_CHAR *message;
  559.       TDS_CHAR *proc_name;
  560.       TDS_CHAR *sql_state;
  561. } TDSMSGINFO;
  563. #ifdef NCBI_FTDS
  564. typedef struct tds_blob_info {
  565.         TDS_CHAR *textvalue;
  566.         TDS_CHAR textptr[16];
  567.         TDS_CHAR timestamp[8];
  568. } TDSBLOBINFO;
  569. #endif
  570. /*
  571. ** This is the current environment as reported by the server
  572. */
  573. typedef struct tds_env_info {
  574. int block_size;
  575. char *language;
  576. char *charset;
  577. char *database;
  578. } TDSENVINFO;
  580. typedef struct tds_dynamic {
  581. char id[30];
  582. int dyn_state;
  583. TDSRESULTINFO *res_info;
  584. int num_params;
  585. TDSINPUTPARAM **params;
  586. } TDSDYNAMIC;
  588. /* forward declaration */
  589. typedef struct tds_context TDSCONTEXT;
  590. typedef struct tds_socket  TDSSOCKET;
  592. struct tds_context {
  593. TDSLOCINFO *locale;
  594. void *parent;
  595. /* handler */
  596. int (*msg_handler)(TDSCONTEXT*, TDSSOCKET*, TDSMSGINFO*);
  597. int (*err_handler)(TDSCONTEXT*, TDSSOCKET*, TDSMSGINFO*);
  598. };
  600. struct tds_socket {
  601. /* fixed and connect time */
  602.         int s;
  603. TDS_SMALLINT major_version;
  604. TDS_SMALLINT minor_version;
  605. unsigned char capabilities[TDS_MAX_CAPABILITY];
  606. unsigned char broken_dates;
  607. /* in/out buffers */
  608. unsigned char *in_buf;
  609. unsigned char *out_buf;
  610. unsigned int in_buf_max;
  611. unsigned in_pos;
  612. unsigned out_pos;
  613. unsigned in_len;
  614. unsigned out_len;
  615. unsigned char out_flag;
  616. unsigned char last_packet;
  617. void *parent;
  618. /* info about current query */
  619. TDSRESULTINFO *res_info;
  620.         TDSCOMPUTEINFO *comp_info;
  621.         TDSPARAMINFO *param_info;
  622. TDS_TINYINT   has_status;
  623. TDS_INT       ret_status;
  624. TDSMSGINFO *msg_info;
  625. TDS_TINYINT   state;
  626. int rows_affected;
  627. /* timeout stuff from Jeff */
  628. TDS_INT timeout;
  629. TDS_INT longquery_timeout;
  630. void (*longquery_func)(long lHint);
  631. long longquery_param;
  632. time_t queryStarttime;
  633. TDSENVINFO *env;
  634. /* dynamic placeholder stuff */
  635. int num_dyns;
  636. int cur_dyn_elem;
  637. TDSDYNAMIC **dyns;
  638. int emul_little_endian;
  639. char *date_fmt;
  640. TDSCONTEXT *tds_ctx;
  641. void *iconv_info;
  642. #ifdef NCBI_FTDS
  643.     /* bcp stuff */
  644.     int                packet_count; 
  645.     int                f_batch; 
  646.     int                rows_in_batch;
  647. #endif   
  649. /** config for login stuff. After login this field is NULL */
  650. TDSCONFIGINFO *config;
  651. };
  653. void tds_set_longquery_handler(TDSLOGIN * tds_login, void (* longquery_func)(long), long longquery_param);
  654. void tds_set_timeouts(TDSLOGIN *tds_login, int connect, int query, int longquery);
  655. int tds_write_packet(TDSSOCKET *tds,unsigned char final);
  656. int tds_init_write_buf(TDSSOCKET *tds);
  657. void tds_free_result_info(TDSRESULTINFO *info);
  658. void tds_free_socket(TDSSOCKET *tds);
  659. void tds_free_config(TDSCONFIGINFO *config);
  660. void tds_free_all_results(TDSSOCKET *tds);
  661. void tds_free_results(TDSRESULTINFO *res_info);
  662. void tds_free_param_results(TDSPARAMINFO *param_info);
  663. void tds_free_column(TDSCOLINFO *column);
  664. void tds_free_msg(TDSMSGINFO *msg_info);
  665. int tds_put_n(TDSSOCKET *tds, const unsigned char *buf, int n);
  666. int tds_put_string(TDSSOCKET *tds, const char *buf, int n);
  667. int tds_put_int(TDSSOCKET *tds, TDS_INT i);
  668. int tds_put_smallint(TDSSOCKET *tds, TDS_SMALLINT si);
  669. int tds_put_tinyint(TDSSOCKET *tds, TDS_TINYINT ti);
  670. int tds_put_byte(TDSSOCKET *tds, unsigned char c);
  671. unsigned char tds_get_byte(TDSSOCKET *tds);
  672. void tds_unget_byte(TDSSOCKET *tds);
  673. TDS_INT tds_get_int(TDSSOCKET *tds);
  674. TDS_SMALLINT tds_get_smallint(TDSSOCKET *tds);
  675. char *tds_get_n(TDSSOCKET *tds, void *dest, int n);
  676. char *tds_get_string(TDSSOCKET *tds, void *dest, int n);
  677. char *tds_get_ntstring(TDSSOCKET *tds, char *dest, int n);
  678. TDSRESULTINFO *tds_alloc_results(int num_cols);
  679. TDSCOMPUTEINFO *tds_alloc_compute_results(int num_cols);
  680. TDSCONTEXT *tds_alloc_context();
  681. void tds_free_context(TDSCONTEXT *locale);
  682. TDSSOCKET *tds_alloc_socket(TDSCONTEXT *context, int bufsize);
  683. TDSCONFIGINFO *tds_get_config(TDSSOCKET *tds, TDSLOGIN *login, TDSLOCINFO *locale);
  684. TDSLOCINFO *tds_get_locale();
  685. void *tds_alloc_row(TDSRESULTINFO *res_info);
  686. char *tds_msg_get_proc_name(TDSSOCKET *tds);
  687. TDSLOGIN *tds_alloc_login();
  688. TDSDYNAMIC *tds_alloc_dynamic(TDSSOCKET *tds, char *id);
  689. void tds_free_login(TDSLOGIN *login);
  690. TDSCONFIGINFO *tds_alloc_config(TDSLOCINFO *locale);
  691. TDSLOCINFO *tds_alloc_locale();
  692. void tds_free_locale(TDSLOCINFO *locale);
  693. TDSSOCKET *tds_connect(TDSLOGIN *login, TDSCONTEXT *context, void *parent);
  694. TDSINPUTPARAM *tds_add_input_param(TDSDYNAMIC *dyn);
  695. void tds_set_packet(TDSLOGIN *tds_login, short packet_size);
  696. void tds_set_port(TDSLOGIN *tds_login, int port);
  697. void tds_set_passwd(TDSLOGIN *tds_login, char *password);
  698. void tds_set_bulk(TDSLOGIN *tds_login, TDS_TINYINT enabled);
  699. void tds_set_user(TDSLOGIN *tds_login, char *username);
  700. void tds_set_app(TDSLOGIN *tds_login, char *application);
  701. void tds_set_host(TDSLOGIN *tds_login, char *hostname);
  702. void tds_set_library(TDSLOGIN *tds_login, char *library);
  703. void tds_set_server(TDSLOGIN *tds_login, char *server);
  704. void tds_set_charset(TDSLOGIN *tds_login, char *charset);
  705. void tds_set_language(TDSLOGIN *tds_login, char *language);
  706. void tds_set_version(TDSLOGIN *tds_login, short major_ver, short minor_ver);
  707. void tds_set_capabilities(TDSLOGIN *tds_login, unsigned char *capabilities, int size);
  708. int tds_submit_query(TDSSOCKET *tds, char *query);
  709. int tds_process_result_tokens(TDSSOCKET *tds);
  710. int tds_process_row_tokens(TDSSOCKET *tds);
  711. int tds_process_env_chg(TDSSOCKET *tds);
  712. int tds_process_default_tokens(TDSSOCKET *tds, int marker);
  713. TDS_INT tds_process_end(TDSSOCKET *tds, int marker, int *more, int *canceled);
  714. int tds_client_msg(TDSCONTEXT *tds_ctx, TDSSOCKET *tds, int msgnum, int level, int state, int line, char *message);
  715. int tds_reset_msg_info(TDSMSGINFO *msg_info);
  716. void  tds_set_parent(TDSSOCKET* tds, void* the_parent);
  717. void* tds_get_parent(TDSSOCKET* tds);
  718. void tds_set_null(unsigned char *current_row, int column);
  719. void tds_clr_null(unsigned char *current_row, int column);
  720. int tds_get_null(unsigned char *current_row, int column);
  721. int tds7_send_login(TDSSOCKET *tds, TDSCONFIGINFO *config);
  722. unsigned char *tds7_crypt_pass(const unsigned char *clear_pass, int len, unsigned char *crypt_pass);
  723. int tds_lookup_dynamic(TDSSOCKET *tds, char *id);
  725. /* iconv.c */
  726. void tds_iconv_open(TDSSOCKET *tds, char *charset);
  727. void tds_iconv_close(TDSSOCKET *tds);
  728. unsigned char *tds7_ascii2unicode(TDSSOCKET *tds, const char *in_string, char *out_string, int maxlen);
  729. char *tds7_unicode2ascii(TDSSOCKET *tds, const char *in_string, char *out_string, int len);
  730.  
  731. /* threadsafe.c */
  732. char *tds_timestamp_str(char *str, int maxlen);
  733. struct hostent *tds_gethostbyname_r(const char *servername, struct hostent *result, char *buffer, int buflen, int *h_errnop);
  734. struct hostent *tds_gethostbyaddr_r(const char *addr, int len, int type, struct hostent *result, char *buffer, int buflen, int *h_errnop);
  735. struct servent *tds_getservbyname_r(const char *name, char *proto, struct servent *result, char *buffer, int buflen);
  736. char *tds_strtok_r(char *s, const char *delim, char **ptrptr);
  738. typedef struct tds_answer
  739. {
  740. unsigned char lm_resp[24];
  741. unsigned char nt_resp[24];
  742. } TDSANSWER;
  743. void tds_answer_challenge(char *passwd, char *challenge,TDSANSWER* answer);
  745. #define IS_TDS42(x) (x->major_version==4 && x->minor_version==2)
  746. #define IS_TDS46(x) (x->major_version==4 && x->minor_version==6)
  747. #define IS_TDS50(x) (x->major_version==5 && x->minor_version==0)
  748. #define IS_TDS70(x) (x->major_version==7 && x->minor_version==0)
  749. #define IS_TDS80(x) (x->major_version==8 && x->minor_version==0)
  751. #define IS_TDS7_PLUS(x) ( IS_TDS70(x) || IS_TDS80(x) )
  753. #ifdef __cplusplus
  754. }
  755. #endif 
  757. #endif /* _tds_h_ */