Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
d42f92d2
Commit
d42f92d2
authored
Jan 10, 2005
by
tomas@poseidon.ndb.mysql.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fixed a number of doxygen warnings
parent
af1dfd74
Changes
14
Hide whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
113 additions
and
53 deletions
+113
-53
ndb/examples/ndbapi_async_example/ndbapi_async.cpp
ndb/examples/ndbapi_async_example/ndbapi_async.cpp
+0
-3
ndb/include/mgmapi/mgmapi.h
ndb/include/mgmapi/mgmapi.h
+23
-12
ndb/include/ndbapi/Ndb.hpp
ndb/include/ndbapi/Ndb.hpp
+3
-3
ndb/include/ndbapi/NdbBlob.hpp
ndb/include/ndbapi/NdbBlob.hpp
+15
-7
ndb/include/ndbapi/NdbDictionary.hpp
ndb/include/ndbapi/NdbDictionary.hpp
+25
-15
ndb/include/ndbapi/NdbError.hpp
ndb/include/ndbapi/NdbError.hpp
+2
-0
ndb/include/ndbapi/NdbEventOperation.hpp
ndb/include/ndbapi/NdbEventOperation.hpp
+4
-1
ndb/include/ndbapi/NdbIndexScanOperation.hpp
ndb/include/ndbapi/NdbIndexScanOperation.hpp
+3
-4
ndb/include/ndbapi/NdbOperation.hpp
ndb/include/ndbapi/NdbOperation.hpp
+3
-0
ndb/include/ndbapi/NdbRecAttr.hpp
ndb/include/ndbapi/NdbRecAttr.hpp
+4
-0
ndb/include/ndbapi/NdbScanOperation.hpp
ndb/include/ndbapi/NdbScanOperation.hpp
+16
-1
ndb/include/ndbapi/NdbTransaction.hpp
ndb/include/ndbapi/NdbTransaction.hpp
+4
-0
ndb/include/ndbapi/ndb_cluster_connection.hpp
ndb/include/ndbapi/ndb_cluster_connection.hpp
+7
-7
ndb/include/ndbapi/ndberror.h
ndb/include/ndbapi/ndberror.h
+4
-0
No files found.
ndb/examples/ndbapi_async_example/ndbapi_async.cpp
View file @
d42f92d2
...
@@ -145,9 +145,6 @@ int create_table(Ndb * myNdb);
...
@@ -145,9 +145,6 @@ int create_table(Ndb * myNdb);
int
tempErrors
=
0
;
int
tempErrors
=
0
;
int
permErrors
=
0
;
int
permErrors
=
0
;
/**
* Helper function for callback(...)
*/
void
void
closeTransaction
(
Ndb
*
ndb
,
async_callback_t
*
cb
)
closeTransaction
(
Ndb
*
ndb
,
async_callback_t
*
cb
)
{
{
...
...
ndb/include/mgmapi/mgmapi.h
View file @
d42f92d2
...
@@ -55,8 +55,9 @@
...
@@ -55,8 +55,9 @@
* struct ndb_mgm_cluster_state *state= ndb_mgm_get_status(handle);
* struct ndb_mgm_cluster_state *state= ndb_mgm_get_status(handle);
* for(int i=0; i < state->no_of_nodes; i++)
* for(int i=0; i < state->no_of_nodes; i++)
* {
* {
* printf("node with ID=%d ", state->node_states[i].node_id);
* struct ndb_mgm_node_state *node_state= &state->node_states[i];
* if(state->node_states[i].version != 0)
* printf("node with ID=%d ", node_state->node_id);
* if(node_state->version != 0)
* printf("connected\n");
* printf("connected\n");
* else
* else
* printf("not connected\n");
* printf("not connected\n");
...
@@ -108,15 +109,15 @@ extern "C" {
...
@@ -108,15 +109,15 @@ extern "C" {
*/
*/
enum
ndb_mgm_node_type
{
enum
ndb_mgm_node_type
{
NDB_MGM_NODE_TYPE_UNKNOWN
=
-
1
/** Node type not known*/
NDB_MGM_NODE_TYPE_UNKNOWN
=
-
1
/** Node type not known*/
,
NDB_MGM_NODE_TYPE_API
/** An application
node (API)
*/
,
NDB_MGM_NODE_TYPE_API
/** An application
(NdbApi) node
*/
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
=
NODE_TYPE_API
=
NODE_TYPE_API
#endif
#endif
,
NDB_MGM_NODE_TYPE_NDB
/** A database node
(DB)
*/
,
NDB_MGM_NODE_TYPE_NDB
/** A database node */
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
=
NODE_TYPE_DB
=
NODE_TYPE_DB
#endif
#endif
,
NDB_MGM_NODE_TYPE_MGM
/** A m
gmt server node (MGM)
*/
,
NDB_MGM_NODE_TYPE_MGM
/** A m
anagement server node
*/
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
=
NODE_TYPE_MGM
=
NODE_TYPE_MGM
#endif
#endif
...
@@ -249,13 +250,15 @@ extern "C" {
...
@@ -249,13 +250,15 @@ extern "C" {
#endif
#endif
/**
/**
* Status of a node in the cluster
* Status of a node in the cluster
.
*
*
* Sub-structure in enum ndb_mgm_cluster_state
* Sub-structure in enum ndb_mgm_cluster_state
* returned by ndb_mgm_get_status()
* returned by ndb_mgm_get_status()
.
*
*
* @note @ref node_status, @ref start_phase, @ref dynamic_id
* @note <var>node_status</var>, <var>start_phase</var>,
* and @ref node_group are relevant only for database nodes
* <var>dynamic_id</var>
* and <var>node_group</var> are relevant only for database nodes,
* i.e. <var>node_type</var> == @ref NDB_MGM_NODE_TYPE_NDB.
*/
*/
struct
ndb_mgm_node_state
{
struct
ndb_mgm_node_state
{
/** NDB Cluster node ID*/
/** NDB Cluster node ID*/
...
@@ -532,11 +535,14 @@ extern "C" {
...
@@ -532,11 +535,14 @@ extern "C" {
* Gets the connectstring used for a connection
* Gets the connectstring used for a connection
*
*
* @note This function returns the default connectstring if no call to
* @note This function returns the default connectstring if no call to
* ndb_mgm_set_connectstring() has been performed
* ndb_mgm_set_connectstring() has been performed. Also, the
* returned connectstring may be formatted differently.
*
*
* @param handle Management handle
* @param handle Management handle
* @param buf Buffer to hold result
* @param buf_sz Size of buffer.
*
*
* @return connectstring
* @return connectstring
(same as <var>buf</var>)
*/
*/
const
char
*
ndb_mgm_get_connectstring
(
NdbMgmHandle
handle
,
char
*
buf
,
int
buf_sz
);
const
char
*
ndb_mgm_get_connectstring
(
NdbMgmHandle
handle
,
char
*
buf
,
int
buf_sz
);
...
@@ -545,6 +551,12 @@ extern "C" {
...
@@ -545,6 +551,12 @@ extern "C" {
* ndb_mgm_set_connectstring().
* ndb_mgm_set_connectstring().
*
*
* @param handle Management handle.
* @param handle Management handle.
* @param no_retries Number of retries to connect
* (0 means connect once).
* @param retry_delay_in_seconds
* How long to wait until retry is performed.
* @param verbose Make printout regarding connect retries.
*
* @return -1 on error.
* @return -1 on error.
*/
*/
int
ndb_mgm_connect
(
NdbMgmHandle
handle
,
int
no_retries
,
int
ndb_mgm_connect
(
NdbMgmHandle
handle
,
int
no_retries
,
...
@@ -913,7 +925,6 @@ extern "C" {
...
@@ -913,7 +925,6 @@ extern "C" {
* Exit Single user mode
* Exit Single user mode
*
*
* @param handle NDB management handle.
* @param handle NDB management handle.
* @param nodeId Node ID of the single user node
* @param reply Reply message.
* @param reply Reply message.
*
*
* @return -1 on error.
* @return -1 on error.
...
...
ndb/include/ndbapi/Ndb.hpp
View file @
d42f92d2
...
@@ -507,7 +507,8 @@
...
@@ -507,7 +507,8 @@
are more frequent than each 10 ms,
are more frequent than each 10 ms,
additional support from the operating system is required.
additional support from the operating system is required.
-# For methods that are affected by the adaptive send alorithm
-# For methods that are affected by the adaptive send alorithm
(such as NdbTransaction::execute()), there is a <var>force</var> parameter
(such as NdbTransaction::execute()), there is a <var>force</var>
parameter
that overrides its default behaviour in this regard and forces
that overrides its default behaviour in this regard and forces
immediate transmission to all nodes. See the inidvidual NDB API class
immediate transmission to all nodes. See the inidvidual NDB API class
listings for more information.
listings for more information.
...
@@ -1345,10 +1346,9 @@ public:
...
@@ -1345,10 +1346,9 @@ public:
int
sendPollNdb
(
int
aMillisecondNumber
=
WAITFOR_RESPONSE_TIMEOUT
,
int
sendPollNdb
(
int
aMillisecondNumber
=
WAITFOR_RESPONSE_TIMEOUT
,
int
minNoOfEventsToWakeup
=
1
,
int
minNoOfEventsToWakeup
=
1
,
int
forceSend
=
0
);
int
forceSend
=
0
);
/** @} *********************************************************************/
#endif
#endif
/** @} *********************************************************************/
/**
/**
* @name Error Handling
* @name Error Handling
* @{
* @{
...
...
ndb/include/ndbapi/NdbBlob.hpp
View file @
d42f92d2
...
@@ -107,6 +107,9 @@ public:
...
@@ -107,6 +107,9 @@ public:
Closed
=
3
,
Closed
=
3
,
Invalid
=
9
Invalid
=
9
};
};
/**
* Get the state of a NdbBlob object.
*/
State
getState
();
State
getState
();
/**
/**
* Inline blob header.
* Inline blob header.
...
@@ -116,7 +119,7 @@ public:
...
@@ -116,7 +119,7 @@ public:
};
};
/**
/**
* Prepare to read blob value. The value is available after execute.
* Prepare to read blob value. The value is available after execute.
* Use getNull
to check for NULL and getLength
to get the real length
* Use getNull
() to check for NULL and getLength()
to get the real length
* and to check for truncation. Sets current read/write position to
* and to check for truncation. Sets current read/write position to
* after the data read.
* after the data read.
*/
*/
...
@@ -129,10 +132,10 @@ public:
...
@@ -129,10 +132,10 @@ public:
*/
*/
int
setValue
(
const
void
*
data
,
Uint32
bytes
);
int
setValue
(
const
void
*
data
,
Uint32
bytes
);
/**
/**
* Callback for setActiveHook. Invoked immediately when the prepared
* Callback for setActiveHook
()
. Invoked immediately when the prepared
* operation has been executed (but not committed). Any getValue or
* operation has been executed (but not committed). Any getValue
()
or
* setValue is done first. The blob handle is active so readData or
* setValue
()
is done first. The blob handle is active so readData or
* writeData etc can be used to manipulate blob value. A user-defined
* writeData
()
etc can be used to manipulate blob value. A user-defined
* argument is passed along. Returns non-zero on error.
* argument is passed along. Returns non-zero on error.
*/
*/
typedef
int
ActiveHook
(
NdbBlob
*
me
,
void
*
arg
);
typedef
int
ActiveHook
(
NdbBlob
*
me
,
void
*
arg
);
...
@@ -195,10 +198,15 @@ public:
...
@@ -195,10 +198,15 @@ public:
const
NdbError
&
getNdbError
()
const
;
const
NdbError
&
getNdbError
()
const
;
/**
/**
* Return info about all blobs in this operation.
* Return info about all blobs in this operation.
*
* Get first blob in list.
*/
*/
// Get first blob in list
NdbBlob
*
blobsFirstBlob
();
NdbBlob
*
blobsFirstBlob
();
// Get next blob in list after this one
/**
* Return info about all blobs in this operation.
*
* Get next blob in list. Initialize with blobsFirstBlob().
*/
NdbBlob
*
blobsNextBlob
();
NdbBlob
*
blobsNextBlob
();
private:
private:
...
...
ndb/include/ndbapi/NdbDictionary.hpp
View file @
d42f92d2
...
@@ -631,7 +631,7 @@ public:
...
@@ -631,7 +631,7 @@ public:
* Assignment operator, deep copy
* Assignment operator, deep copy
* @param table Table to be copied
* @param table Table to be copied
*/
*/
Table
&
operator
=
(
const
Table
&
);
Table
&
operator
=
(
const
Table
&
table
);
/**
/**
* Name of table
* Name of table
...
@@ -946,12 +946,12 @@ public:
...
@@ -946,12 +946,12 @@ public:
#endif
#endif
};
};
/*
/*
*
* Constructor
* Constructor
* @param name Name of event
* @param name Name of event
*/
*/
Event
(
const
char
*
name
);
Event
(
const
char
*
name
);
/*
/*
*
* Constructor
* Constructor
* @param name Name of event
* @param name Name of event
* @param table Reference retrieved from NdbDictionary
* @param table Reference retrieved from NdbDictionary
...
@@ -994,9 +994,12 @@ public:
...
@@ -994,9 +994,12 @@ public:
*/
*/
void
addTableEvent
(
const
TableEvent
te
);
void
addTableEvent
(
const
TableEvent
te
);
/**
/**
* Get/set durability of the event
* Set durability of the event
*/
void
setDurability
(
EventDurability
);
/**
* Get durability of the event
*/
*/
void
setDurability
(
EventDurability
ed
);
EventDurability
getDurability
()
const
;
EventDurability
getDurability
()
const
;
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
void
addColumn
(
const
Column
&
c
);
void
addColumn
(
const
Column
&
c
);
...
@@ -1116,6 +1119,13 @@ public:
...
@@ -1116,6 +1119,13 @@ public:
/**
/**
* Fetch list of all objects, optionally restricted to given type.
* Fetch list of all objects, optionally restricted to given type.
*
* @param list List of objects returned in the dictionary
* @param type Restrict returned list to only contain objects of
* this type
*
* @return -1 if error.
*
*/
*/
int
listObjects
(
List
&
list
,
Object
::
Type
type
=
Object
::
TypeUndefined
);
int
listObjects
(
List
&
list
,
Object
::
Type
type
=
Object
::
TypeUndefined
);
int
listObjects
(
List
&
list
,
int
listObjects
(
List
&
list
,
...
@@ -1168,10 +1178,10 @@ public:
...
@@ -1168,10 +1178,10 @@ public:
/**
/**
* Create event given defined Event instance
* Create event given defined Event instance
* @param Event to create
* @param
event
Event to create
* @return 0 if successful otherwise -1.
* @return 0 if successful otherwise -1.
*/
*/
int
createEvent
(
const
Event
&
);
int
createEvent
(
const
Event
&
event
);
/**
/**
* Drop event with given name
* Drop event with given name
...
@@ -1199,17 +1209,17 @@ public:
...
@@ -1199,17 +1209,17 @@ public:
/**
/**
* Create defined table given defined Table instance
* Create defined table given defined Table instance
* @param
T
able Table to create
* @param
t
able Table to create
* @return 0 if successful otherwise -1.
* @return 0 if successful otherwise -1.
*/
*/
int
createTable
(
const
Table
&
);
int
createTable
(
const
Table
&
table
);
/**
/**
* Drop table given retrieved Table instance
* Drop table given retrieved Table instance
* @param
T
able Table to drop
* @param
t
able Table to drop
* @return 0 if successful otherwise -1.
* @return 0 if successful otherwise -1.
*/
*/
int
dropTable
(
Table
&
);
int
dropTable
(
Table
&
table
);
/**
/**
* Drop table given table name
* Drop table given table name
...
@@ -1220,12 +1230,12 @@ public:
...
@@ -1220,12 +1230,12 @@ public:
/**
/**
* Alter defined table given defined Table instance
* Alter defined table given defined Table instance
* @param
T
able Table to alter
* @param
t
able Table to alter
* @return -2 (incompatible version) <br>
* @return -2 (incompatible version) <br>
* -1 general error <br>
* -1 general error <br>
* 0 success
* 0 success
*/
*/
int
alterTable
(
const
Table
&
);
int
alterTable
(
const
Table
&
table
);
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
/**
/**
...
@@ -1257,10 +1267,10 @@ public:
...
@@ -1257,10 +1267,10 @@ public:
/**
/**
* Create index given defined Index instance
* Create index given defined Index instance
* @param Index to create
* @param
index
Index to create
* @return 0 if successful otherwise -1.
* @return 0 if successful otherwise -1.
*/
*/
int
createIndex
(
const
Index
&
);
int
createIndex
(
const
Index
&
index
);
/**
/**
* Drop index with given name
* Drop index with given name
...
...
ndb/include/ndbapi/NdbError.hpp
View file @
d42f92d2
...
@@ -204,6 +204,7 @@ struct NdbError {
...
@@ -204,6 +204,7 @@ struct NdbError {
*/
*/
char
*
details
;
char
*
details
;
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
NdbError
(){
NdbError
(){
status
=
UnknownResult
;
status
=
UnknownResult
;
classification
=
NoError
;
classification
=
NoError
;
...
@@ -227,6 +228,7 @@ struct NdbError {
...
@@ -227,6 +228,7 @@ struct NdbError {
ndberror
.
details
=
details
;
ndberror
.
details
=
details
;
return
ndberror
;
return
ndberror
;
}
}
#endif
};
};
class
NdbOut
&
operator
<<
(
class
NdbOut
&
,
const
NdbError
&
);
class
NdbOut
&
operator
<<
(
class
NdbOut
&
,
const
NdbError
&
);
...
...
ndb/include/ndbapi/NdbEventOperation.hpp
View file @
d42f92d2
...
@@ -132,7 +132,7 @@ public:
...
@@ -132,7 +132,7 @@ public:
* next() has returned a value greater than
* next() has returned a value greater than
* zero. If a specific attribute has not changed the corresponding
* zero. If a specific attribute has not changed the corresponding
* NdbRecAttr will be in state UNDEFINED. This is checked by
* NdbRecAttr will be in state UNDEFINED. This is checked by
* NdbRecAttr::isN
ull
() which then returns -1.
* NdbRecAttr::isN
ULL
() which then returns -1.
*
*
* @param anAttrName Attribute name
* @param anAttrName Attribute name
* @param aValue If this is non-NULL, then the attribute value
* @param aValue If this is non-NULL, then the attribute value
...
@@ -144,6 +144,9 @@ public:
...
@@ -144,6 +144,9 @@ public:
* (indicating error).
* (indicating error).
*/
*/
NdbRecAttr
*
getValue
(
const
char
*
anAttrName
,
char
*
aValue
=
0
);
NdbRecAttr
*
getValue
(
const
char
*
anAttrName
,
char
*
aValue
=
0
);
/**
* See getValue().
*/
NdbRecAttr
*
getPreValue
(
const
char
*
anAttrName
,
char
*
aValue
=
0
);
NdbRecAttr
*
getPreValue
(
const
char
*
anAttrName
,
char
*
aValue
=
0
);
/**
/**
...
...
ndb/include/ndbapi/NdbIndexScanOperation.hpp
View file @
d42f92d2
...
@@ -45,7 +45,7 @@ public:
...
@@ -45,7 +45,7 @@ public:
* @returns 0 for success and -1 for failure
* @returns 0 for success and -1 for failure
* @see NdbScanOperation::readTuples
* @see NdbScanOperation::readTuples
*/
*/
int
readTuples
(
LockMode
=
LM_Read
,
int
readTuples
(
LockMode
lock_mode
=
LM_Read
,
Uint32
batch
=
0
,
Uint32
batch
=
0
,
Uint32
parallel
=
0
,
Uint32
parallel
=
0
,
bool
order_by
=
false
,
bool
order_by
=
false
,
...
@@ -90,15 +90,14 @@ public:
...
@@ -90,15 +90,14 @@ public:
* An index stores also all-NULL keys. Doing index scan with empty
* An index stores also all-NULL keys. Doing index scan with empty
* bound set returns all table tuples.
* bound set returns all table tuples.
*
*
* @param attrName Attribute name, alternatively:
* @param attr Attribute name, alternatively:
* @param anAttrId Index column id (starting from 0)
* @param type Type of bound
* @param type Type of bound
* @param value Pointer to bound value, 0 for NULL
* @param value Pointer to bound value, 0 for NULL
* @param len Value length in bytes.
* @param len Value length in bytes.
* Fixed per datatype and can be omitted
* Fixed per datatype and can be omitted
* @return 0 if successful otherwise -1
* @return 0 if successful otherwise -1
*/
*/
int
setBound
(
const
char
*
attr
,
int
type
,
const
void
*
aV
alue
,
Uint32
len
=
0
);
int
setBound
(
const
char
*
attr
,
int
type
,
const
void
*
v
alue
,
Uint32
len
=
0
);
/**
/**
* Define bound on index key in range scan using index column id.
* Define bound on index key in range scan using index column id.
...
...
ndb/include/ndbapi/NdbOperation.hpp
View file @
d42f92d2
...
@@ -966,6 +966,7 @@ protected:
...
@@ -966,6 +966,7 @@ protected:
#include <stdlib.h>
#include <stdlib.h>
#endif
#endif
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
inline
inline
int
int
...
@@ -1215,4 +1216,6 @@ NdbOperation::setValue(Uint32 anAttrId, double aPar)
...
@@ -1215,4 +1216,6 @@ NdbOperation::setValue(Uint32 anAttrId, double aPar)
return
setValue
(
anAttrId
,
(
const
char
*
)
&
aPar
,
(
Uint32
)
8
);
return
setValue
(
anAttrId
,
(
const
char
*
)
&
aPar
,
(
Uint32
)
8
);
}
}
#endif // doxygen
#endif
#endif
ndb/include/ndbapi/NdbRecAttr.hpp
View file @
d42f92d2
...
@@ -281,6 +281,8 @@ private:
...
@@ -281,6 +281,8 @@ private:
const
NdbDictionary
::
Column
*
m_column
;
const
NdbDictionary
::
Column
*
m_column
;
};
};
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
inline
inline
NdbDictionary
::
Column
::
Type
NdbDictionary
::
Column
::
Type
NdbRecAttr
::
getType
()
const
{
NdbRecAttr
::
getType
()
const
{
...
@@ -457,5 +459,7 @@ NdbRecAttr::isNULL() const
...
@@ -457,5 +459,7 @@ NdbRecAttr::isNULL() const
class
NdbOut
&
operator
<<
(
class
NdbOut
&
,
const
NdbRecAttr
&
);
class
NdbOut
&
operator
<<
(
class
NdbOut
&
,
const
NdbRecAttr
&
);
#endif // ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#endif
#endif
ndb/include/ndbapi/NdbScanOperation.hpp
View file @
d42f92d2
...
@@ -70,7 +70,8 @@ public:
...
@@ -70,7 +70,8 @@ public:
* NdbOperation::getValue are updated with values
* NdbOperation::getValue are updated with values
* from the scanned tuple.
* from the scanned tuple.
*
*
* @param fetchAllowed If set to false, then fetching is disabled
* @param fetchAllowed If set to false, then fetching is disabled
* @param forceSend If true send will occur immediately (see @ref secAdapt)
*
*
* The NDB API will contact the NDB Kernel for more tuples
* The NDB API will contact the NDB Kernel for more tuples
* when necessary to do so unless you set the fetchAllowed
* when necessary to do so unless you set the fetchAllowed
...
@@ -122,6 +123,13 @@ public:
...
@@ -122,6 +123,13 @@ public:
* @return an NdbOperation or NULL.
* @return an NdbOperation or NULL.
*/
*/
NdbOperation
*
updateCurrentTuple
();
NdbOperation
*
updateCurrentTuple
();
/**
* Update current tuple
*
* @param updateTrans Transaction that should perform the update
*
* @return an NdbOperation or NULL.
*/
NdbOperation
*
updateCurrentTuple
(
NdbTransaction
*
updateTrans
);
NdbOperation
*
updateCurrentTuple
(
NdbTransaction
*
updateTrans
);
/**
/**
...
@@ -129,6 +137,13 @@ public:
...
@@ -129,6 +137,13 @@ public:
* @return 0 on success or -1 on failure
* @return 0 on success or -1 on failure
*/
*/
int
deleteCurrentTuple
();
int
deleteCurrentTuple
();
/**
* Delete current tuple
*
* @param takeOverTransaction Transaction that should perform the delete
*
* @return 0 on success or -1 on failure
*/
int
deleteCurrentTuple
(
NdbTransaction
*
takeOverTransaction
);
int
deleteCurrentTuple
(
NdbTransaction
*
takeOverTransaction
);
/**
/**
...
...
ndb/include/ndbapi/NdbTransaction.hpp
View file @
d42f92d2
...
@@ -796,6 +796,8 @@ private:
...
@@ -796,6 +796,8 @@ private:
void
define_scan_op
(
NdbIndexScanOperation
*
);
void
define_scan_op
(
NdbIndexScanOperation
*
);
};
};
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
inline
inline
Uint32
Uint32
NdbTransaction
::
get_send_size
()
NdbTransaction
::
get_send_size
()
...
@@ -1034,4 +1036,6 @@ NdbTransaction::ptr2int(){
...
@@ -1034,4 +1036,6 @@ NdbTransaction::ptr2int(){
typedef
NdbTransaction
NdbConnection
;
typedef
NdbTransaction
NdbConnection
;
#endif // ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
#endif
#endif
ndb/include/ndbapi/ndb_cluster_connection.hpp
View file @
d42f92d2
...
@@ -34,10 +34,10 @@ public:
...
@@ -34,10 +34,10 @@ public:
/**
/**
* Create a connection to a cluster of storage nodes
* Create a connection to a cluster of storage nodes
*
*
* @param
specify t
he connectstring for where to find the
* @param
connectstring T
he connectstring for where to find the
* management server
*
management server
*/
*/
Ndb_cluster_connection
(
const
char
*
connect
_
string
=
0
);
Ndb_cluster_connection
(
const
char
*
connectstring
=
0
);
~
Ndb_cluster_connection
();
~
Ndb_cluster_connection
();
/**
/**
...
@@ -66,10 +66,10 @@ public:
...
@@ -66,10 +66,10 @@ public:
/**
/**
* Wait until the requested connection with one or more storage nodes is successful
* Wait until the requested connection with one or more storage nodes is successful
*
*
* @param time
_out_for_first_alive n
umber of seconds to wait until
* @param time
out_for_first_alive N
umber of seconds to wait until
* first live node is detected
*
first live node is detected
* @param timeout_after_first_alive
n
umber of seconds to wait after
* @param timeout_after_first_alive
N
umber of seconds to wait after
* first live node is detected
*
first live node is detected
*
*
* @return = 0 all nodes live,
* @return = 0 all nodes live,
* > 0 at least one node live,
* > 0 at least one node live,
...
...
ndb/include/ndbapi/ndberror.h
View file @
d42f92d2
...
@@ -21,6 +21,8 @@
...
@@ -21,6 +21,8 @@
extern
"C"
{
extern
"C"
{
#endif
#endif
#ifndef DOXYGEN_SHOULD_SKIP_INTERNAL
typedef
enum
typedef
enum
{
{
ndberror_st_success
=
0
,
ndberror_st_success
=
0
,
...
@@ -93,6 +95,8 @@ const char *ndberror_classification_message(ndberror_classification);
...
@@ -93,6 +95,8 @@ const char *ndberror_classification_message(ndberror_classification);
void
ndberror_update
(
ndberror_struct
*
);
void
ndberror_update
(
ndberror_struct
*
);
int
ndb_error_string
(
int
err_no
,
char
*
str
,
unsigned
int
size
);
int
ndb_error_string
(
int
err_no
,
char
*
str
,
unsigned
int
size
);
#endif
/* doxygen skip internal*/
#ifdef __cplusplus
#ifdef __cplusplus
}
}
#endif
#endif
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment