RemoteDbDataProvider::RemoteDbTableBulkSendOperation Class Reference

Bulk insert object for remote tables; uses multiplexed I/O. More...

Inheritance diagram for RemoteDbDataProvider::RemoteDbTableBulkSendOperation:

Collaboration diagram for RemoteDbDataProvider::RemoteDbTableBulkSendOperation:

Public Member Methods
	constructor (RemoteDbTableDataProvider provider, DbRemoteBase remote, string table, string stream, *hash< auto > opts)
	Creates the object. More...
	queueData (hash< auto > record)
	Queues data in the buffer.
	queueData (list< hash< auto > > records)
	Queues data in the buffer.
	flush ()
	Flushes any remaining data to the data provider. More...
	discard ()
	Discards any buffered data. More...

Private Attributes
int	tid = gettid()
	This object can only be used from the thread where it was created.
DbRemoteBase	remote
	The remote connection.
string	table
	The table name.
string	stream
	The stream to use.
*hash< auto >	opts
	Options to use when creating the remote send object.
DbRemoteSend	send
	The bulk send operation.

Detailed Description

Bulk insert object for remote tables; uses multiplexed I/O.

See also

DbRemoteSend for more information

Member Function Documentation

constructor()

RemoteDbDataProvider::RemoteDbTableBulkSendOperation::constructor	(	RemoteDbTableDataProvider	provider,
		DbRemoteBase	remote,
		string	table,
		string	stream,
		*hash< auto >	opts
	)

Creates the object.

Parameters

provider	the remote data provider (parent object)
remote	the remote connection
table	the remote table name
stream	the stream name
opts	bulk send options

Note

that the actual bulk send object is created on demand; once the bulk send operation is in progress, no other I/O can be done on the same connection

discard()

RemoteDbDataProvider::RemoteDbTableBulkSendOperation::discard ( )

virtual

Discards any buffered data.

This method should be called before rolling back the transaction (if the data provider supports transaction management) or destroying the object if an error occurs

Implements DataProvider::AbstractDataProviderBulkOperation.

flush()

RemoteDbDataProvider::RemoteDbTableBulkSendOperation::flush ( )

virtual

Flushes any remaining data to the data provider.

This method should always be called before committing the transaction (if the data provider supports transaction management) or destroying the object

Implements DataProvider::AbstractDataProviderBulkOperation.

---

The documentation for this class was generated from the following file:

• RemoteDbTableBulkSendOperation.qc