Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/ftds14_2freetds_2tds_2bulk_8c_source.html below:

NCBI C++ ToolKit: src/dbapi/driver/ftds14/freetds/tds/bulk.c Source File

,

* rowbuffer,

start);

fmt =

;

fmt =

;

column_type[40];

(clause->

< strlen(clause->

)

+ strlen(column_type)

+ ((

) ? 2u : 4u)) {

*temp =

(

, 2 * clause->

);

strcpy(temp, clause->

);

*

(

* s)

= strcspn(s,

);

(s[

] ==

) {

(

= 0;

<

;

++) {

, firstcol, erc;

clause_buffer[4096] = { 0 };

triggers_checked = !bcpinfo->

;

colclause.

= clause_buffer;

colclause.

=

(clause_buffer);

( !triggers_checked ) {

(strstr(uc_hint,

)) {

(uc_hint != bcpinfo->

) {

((

*)uc_hint);

triggers_checked =

;

(bcpinfo->

) {

(

(&hint,

, bcpinfo->

) < 0)

(start_col == 0) {

*save_data;

has_text =

;

rc = get_col_data(bcpinfo, bindcol,

);

null_error(bcpinfo,

,

);

}

(has_text) {

memset(&blob, 0,

(blob));

var_cols_written = 0;

memset(record,

, old_record_size);

row_sz_pos = row_pos;

(var_cols_written) {

record[0] = var_cols_written;

(start_col == 0) {

start_col = bcpinfo->

;

, bcpinfo, get_col_data, null_error,

);

,

* rowbuffer,

start)

bitleft = 0, bitpos = 0;

bcpinfo, get_col_data, null_error,

, rowbuffer, start);

null_error(bcpinfo,

,

);

memcpy(&rowbuffer[row_pos], num->

, cpbytes);

rowbuffer[bitpos] = 0;

rowbuffer[bitpos] |= 256 >> bitleft;

memset(rowbuffer + row_pos + cpbytes,

, column_size - cpbytes);

row_pos += column_size;

, row_pos;

ncols = 0;

(

= bcpinfo->

; i < bcpinfo->bindinfo->num_cols;

++) {

cpbytes = 0;

null_error(bcpinfo,

,

);

memcpy(&rowbuffer[row_pos], num->

, cpbytes);

rowbuffer[row_pos] =

;

pfx_top =

[ncols] / 256;

n_pfx = 1;

(

= 0;

<= ncols ; ++

)

((

[

] / 256u) < pfx_top)

(

=0;

<= ncols;

++)

*poff++ =

[ncols-

] & 0xFF;

row_pos = (

)(poff - rowbuffer);

ncols == 0? start : row_pos;

converted_len;

*converted_name;

(!converted_name) {

(!converted_name) {

(

= 0;

< res_info->

; ++

, ++syb_info) {

src = (

*) ((

*)src)->textvalue;

( !syb_info->

) {

row_match =

;

(icol = 0; icol < res_info->

; ++icol) {

cols_pos[scol] = icol;

col_flags |= 1 << scol;

col_flags |= 1 << icol;

cols_values[icol] = dres.

;

(colinfo->

) {

ret = get_col_data(bulk, bcpcol,

);

((nullind !=

&& nullind[

] == -1)

|| !syb_info->

) {

fixed_col_len_tot = 0;

variable_col_len_tot = 0;

column_bcp_data_size = 0;

bcp_record_size = 0;

column_bcp_data_size = 16;

variable_col_len_tot += column_bcp_data_size;

fixed_col_len_tot += column_bcp_data_size;

bcp_record_size = 4 +

variable_col_len_tot +

( (

)(variable_col_len_tot / 256 ) + 1 ) +

*p = (

*) ptr;

p - (

*) ptr;

c = getc_unlocked(s->

);

p - (

*) ptr;

.term_len = term_len;

.left =

(

, term_len*3);

memcpy(

.left + term_len,

, term_len);

memcpy(

.left + term_len*2u,

, term_len);

.terminator =

.left + term_len*2u;

readed = fread(

.left, 1, term_len, stream);

(readed != term_len) {

(readed == 0 && feof(stream))

(char_conv ==

)

funlockfile(stream);

*outbytes = w.

;

,

objname, textptr, timestamp, with_log ?

:

);

(bcpinfo && colinfo &&

static void cleanup(void)

#define TDS_PUT_UA2LE(ptr, val)

#define CHECK_TDS_EXTRA(tds)

static DLIST_TYPE *DLIST_NAME() first(DLIST_LIST_TYPE *list)

#define TDS7_RESULT_TOKEN

#define is_numeric_type(x)

#define TDS_DONEPROC_RESULT

#define TDS_ROWFMT_RESULT

tds_sysdep_int32_type TDS_INT

#define TDS_PUT_BYTE(tds, v)

#define TDS_NO_MORE_RESULTS

void(* tds_bcp_null_error)(TDSBCPINFO *bulk, int index, int offset)

@ TDS_PENDING

cilent is waiting for data

@ TDS_SENDING

client would send data

@ TDS_WRITING

client is writing data

tds_sysdep_int16_type TDS_SMALLINT

#define tds_convert_string_free(original, converted)

TDSRET(* tds_bcp_get_col_data)(TDSBCPINFO *bulk, TDSCOLUMN *bcpcol, int offset)

#define tds_new0(type, n)

#define is_nullable_type(x)

@ TDS_DONE_ERROR

error occurred

tds_sysdep_uint16_type TDS_USMALLINT

#define TDS_RESIZE(p, n_elem)

tds_sysdep_uint32_type TDS_UINT

#define TDS_PUT_SMALLINT(tds, v)

#define TDS_DONEINPROC_RESULT

TDSRET tds_bcp_start_copy_in(TDSSOCKET *tds, TDSBCPINFO *bcpinfo)

Start bulk copy to server \tds.

TDSRET tds_writetext_start(TDSSOCKET *tds, const char *objname, const char *textptr, const char *timestamp, int with_log, TDS_UINT size)

Start writing writetext request.

TDSRET tds_bcp_start(TDSSOCKET *tds, TDSBCPINFO *bcpinfo)

Start sending BCP data to server.

TDSRET tds_bcp_fread(TDSSOCKET *tds, TDSICONV *char_conv, FILE *stream, const char *terminator, size_t term_len, char **outbuf, size_t *outbytes)

Read a data file, passing the data through iconv().

TDSRET tds_writetext_continue(TDSSOCKET *tds, const TDS_UCHAR *text, TDS_UINT size)

Send some data in the writetext request started by tds_writetext_start.

TDSRET tds_writetext_end(TDSSOCKET *tds)

Finish sending writetext data.

struct tds_file_stream TDSFILESTREAM

input stream to read a file

TDSRET tds_bcp_init(TDSSOCKET *tds, TDSBCPINFO *bcpinfo)

Initialize BCP information.

TDSRET tds_bcp_send_record(TDSSOCKET *tds, TDSBCPINFO *bcpinfo, tds_bcp_get_col_data get_col_data, tds_bcp_null_error null_error, int offset)

Send one row of data to server \tds.

TDSRET tds_bcp_done(TDSSOCKET *tds, int *rows_copied)

Tell we finished sending BCP data to server \tds.

struct tds_pbcb TDSPBCB

Holds clause buffer.

#define tds_alloc_results

#define tds_convert_stream

#define tds_connection_close

#define tds_dynamic_stream_init

#define tds_process_simple_query

#define tds_get_column_declaration

#define tds_convert_string

#define tds_numeric_bytes_per_prec

#define tds_alloc_bcp_column_data

#define tds_submit_queryf

#define tds_get_conversion_type

#define tds_process_tokens

#define TDS_PROPAGATE(rc)

static int tds5_bulk_insert_column(const char *name)

static void tds5_swap_data(const TDSCOLUMN *col, void *p)

static TDSRET tds5_send_record(TDSSOCKET *tds, TDSBCPINFO *bcpinfo, tds_bcp_get_col_data get_col_data, tds_bcp_null_error null_error, int offset, int start_col)

static int tds_file_stream_read(TDSINSTREAM *stream, void *ptr, size_t len)

Reads a chunk of data from file stream checking for terminator.

static TDSRET tds7_build_bulk_insert_stmt(TDSSOCKET *tds, TDSPBCB *clause, TDSCOLUMN *bcpcol, int first)

Help to build query to be sent to server.

static TDSRET tds7_bcp_send_colmetadata(TDSSOCKET *tds, TDSBCPINFO *bcpinfo)

Send BCP metadata to server.

static int tds5_bcp_add_variable_columns(TDSBCPINFO *bcpinfo, tds_bcp_get_col_data get_col_data, tds_bcp_null_error null_error, int offset, TDS_UCHAR *rowbuffer, int start, int *pncols)

Add variable size columns to the row.

static void tds_bcp_row_free(TDSRESULTINFO *result, unsigned char *row)

Free row data allocated in the result set.

static TDSRET tds5_send_non_blobs(TDSSOCKET *tds, TDSBCPINFO *bcpinfo, tds_bcp_get_col_data get_col_data, tds_bcp_null_error null_error, int offset)

static const char * uc_str(const char *s)

static int tds_bcp_is_bound(TDSBCPINFO *bcpinfo, TDSCOLUMN *colinfo)

static void tds5_read_bulk_defaults(TDSRESULTINFO *res_info, TDSBCPINFO *bcpinfo)

static int tds5_bcp_add_fixed_columns(TDSBCPINFO *bcpinfo, tds_bcp_get_col_data get_col_data, tds_bcp_null_error null_error, int offset, unsigned char *rowbuffer, int start)

Add fixed size columns to the row.

static TDSRET tds5_get_col_data_or_dflt(tds_bcp_get_col_data get_col_data, TDSBCPINFO *bulk, TDSCOLUMN *bcpcol, int offset, int colnum)

static TDSRET tds5_process_insert_bulk_reply(TDSSOCKET *tds, TDSBCPINFO *bcpinfo)

static TDSRET tds_bcp_start_insert_stmt(TDSSOCKET *tds, TDSBCPINFO *bcpinfo)

Prepare the query to be sent to server to request BCP information \tds.

static TDSRET tds7_send_record(TDSSOCKET *tds, TDSBCPINFO *bcpinfo, tds_bcp_get_col_data get_col_data, tds_bcp_null_error null_error, int offset, int start_col)

static const char * tds_dstr_cstr(DSTR *s)

Returns a C version (NUL terminated string) of dstr.

DSTR * tds_dstr_dup(DSTR *s, const DSTR *src) TDS_WUR

Duplicate a string from another dynamic string.

static size_t tds_dstr_len(DSTR *s)

Returns the length of the string in bytes.

unsigned int

A callback function used to compare two keys in a database.

static void text(MDB_val *v)

const struct ncbi::grid::netcache::search::fields::SIZE size

#define MIN(a, b)

returns smaller of a and b.

#define MAX(a, b)

returns larger of a and b.

double r(size_t dimension_, const Int4 *score_, const double *prob_, double theta_)

static PCRE2_SIZE * offsets

#define row(bind, expected)

TDS_INT identity_insert_on

TDS5COLINFO * sybase_colinfo

Information about blobs (e.g.

tds_func_put_info * put_info

Send metadata column information to server.

tds_func_put_data * put_data

Send column data to server.

Metadata about columns in regular and compute rows.

TDS_TINYINT column_varint_size

size of length when reading from wire (0, 1, 2 or 4)

TDS_INT column_size

maximun size of data.

TDS_SMALLINT * column_nullbind

unsigned int column_timestamp

BCPCOLDATA * bcp_column_data

TDS_UCHAR column_collation[5]

const TDSCOLUMNFUNCS * funcs

unsigned char column_computed

TDS_TINYINT column_prec

precision for decimal/numeric

TDS_SERVER_TYPE column_type

This type can be different from wire type because conversion (e.g.

unsigned int column_identity

TDSICONV * char_conv

refers to previously allocated iconv information

unsigned int column_nullable

TDS_TINYINT column_scale

scale for decimal/numeric

unsigned char * column_data

struct tds_column::@124 on_server

TDS_CHAR * column_varaddr

TDS_INT column_cur_size

size written in variable (ie: char, text, binary).

output stream to write data to a dynamic buffer

size_t size

size of data inside buffer

input stream to read a file

const char * terminator

terminator

FILE * f

file to read from

size_t term_len

terminator length in bytes

TDSINSTREAM stream

common fields, must be the first field

char * left

buffer for store bytes readed that could be the terminator

define a stream of data used for input

int(* write)(struct tds_output_stream *stream, size_t len)

write len bytes from buffer, return <0 if error or len

char * buffer

write buffer.

unsigned int from_malloc

true is buffer came from malloc

unsigned int cb

buffer length

Hold information for any results.

unsigned char * current_row

void(* row_free)(struct tds_result_info *result, unsigned char *row)

Information for a server connection.

TDS_INT8 rows_affected

rows updated/deleted/inserted/selected, TDS_NO_COUNT if not valid

TDS_TINYINT bulk_query

true is query sent was a bulk query so we need to switch state to QUERYING

unsigned char out_flag

output buffer type

TDSRESULTINFO * current_results

Current query information.

uchar outbuf[(1000000+1000000)]

voidp calloc(uInt items, uInt size)

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4