#include "sqliteDB.h"
-#define SQL_PREPARE(cct, params, sdb, stmt, ret, Op) \
+#define SQL_PREPARE(dpp, params, sdb, stmt, ret, Op) \
do { \
string schema; \
schema = Schema(params); \
sqlite3_prepare_v2 (*sdb, schema.c_str(), \
-1, &stmt , NULL); \
if (!stmt) { \
- dbout(cct, 0) <<"failed to prepare statement " \
+ ldpp_dout(dpp, 0) <<"failed to prepare statement " \
<<"for Op("<<Op<<"); Errmsg -"\
- <<sqlite3_errmsg(*sdb)<< dbendl;\
+ <<sqlite3_errmsg(*sdb)<< dendl;\
ret = -1; \
goto out; \
} \
- dbout(cct, 20)<<"Successfully Prepared stmt for Op("<<Op \
- <<") schema("<<schema<<") stmt("<<stmt<<")"<< dbendl; \
+ ldpp_dout(dpp, 20)<<"Successfully Prepared stmt for Op("<<Op \
+ <<") schema("<<schema<<") stmt("<<stmt<<")"<< dendl; \
ret = 0; \
} while(0);
-#define SQL_BIND_INDEX(cct, stmt, index, str, sdb) \
+#define SQL_BIND_INDEX(dpp, stmt, index, str, sdb) \
do { \
index = sqlite3_bind_parameter_index(stmt, str); \
\
if (index <=0) { \
- dbout(cct, 0) <<"failed to fetch bind parameter"\
+ ldpp_dout(dpp, 0) <<"failed to fetch bind parameter"\
" index for str("<<str<<") in " \
<<"stmt("<<stmt<<"); Errmsg -" \
- <<sqlite3_errmsg(*sdb)<< dbendl; \
+ <<sqlite3_errmsg(*sdb)<< dendl; \
rc = -1; \
goto out; \
} \
- dbout(cct, 20)<<"Bind parameter index for str(" \
+ ldpp_dout(dpp, 20)<<"Bind parameter index for str(" \
<<str<<") in stmt("<<stmt<<") is " \
- <<index<< dbendl; \
+ <<index<< dendl; \
}while(0);
-#define SQL_BIND_TEXT(cct, stmt, index, str, sdb) \
+#define SQL_BIND_TEXT(dpp, stmt, index, str, sdb) \
do { \
rc = sqlite3_bind_text(stmt, index, str, -1, SQLITE_TRANSIENT); \
\
if (rc != SQLITE_OK) { \
- dbout(cct, 0)<<"sqlite bind text failed for index(" \
+ ldpp_dout(dpp, 0)<<"sqlite bind text failed for index(" \
<<index<<"), str("<<str<<") in stmt(" \
<<stmt<<"); Errmsg - "<<sqlite3_errmsg(*sdb) \
- << dbendl; \
+ << dendl; \
rc = -1; \
goto out; \
} \
}while(0);
-#define SQL_BIND_INT(cct, stmt, index, num, sdb) \
+#define SQL_BIND_INT(dpp, stmt, index, num, sdb) \
do { \
rc = sqlite3_bind_int(stmt, index, num); \
\
if (rc != SQLITE_OK) { \
- dbout(cct, 0)<<"sqlite bind int failed for index(" \
+ ldpp_dout(dpp, 0)<<"sqlite bind int failed for index(" \
<<index<<"), num("<<num<<") in stmt(" \
<<stmt<<"); Errmsg - "<<sqlite3_errmsg(*sdb) \
- << dbendl; \
+ << dendl; \
rc = -1; \
goto out; \
} \
}while(0);
-#define SQL_BIND_BLOB(cct, stmt, index, blob, size, sdb) \
+#define SQL_BIND_BLOB(dpp, stmt, index, blob, size, sdb) \
do { \
rc = sqlite3_bind_blob(stmt, index, blob, size, SQLITE_TRANSIENT); \
\
if (rc != SQLITE_OK) { \
- dbout(cct, 0)<<"sqlite bind blob failed for index(" \
+ ldpp_dout(dpp, 0)<<"sqlite bind blob failed for index(" \
<<index<<"), blob("<<blob<<") in stmt(" \
<<stmt<<"); Errmsg - "<<sqlite3_errmsg(*sdb) \
- << dbendl; \
+ << dendl; \
rc = -1; \
goto out; \
} \
}while(0);
-#define SQL_ENCODE_BLOB_PARAM(cct, stmt, index, param, sdb) \
+#define SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, param, sdb) \
do { \
bufferlist b; \
encode(param, b); \
- SQL_BIND_BLOB(cct, stmt, index, b.c_str(), b.length(), sdb); \
+ SQL_BIND_BLOB(dpp, stmt, index, b.c_str(), b.length(), sdb); \
}while(0);
-#define SQL_READ_BLOB(cct, stmt, index, void_ptr, len) \
+#define SQL_READ_BLOB(dpp, stmt, index, void_ptr, len) \
do { \
void_ptr = NULL; \
void_ptr = (void *)sqlite3_column_blob(stmt, index); \
len = sqlite3_column_bytes(stmt, index); \
\
if (!void_ptr || len == 0) { \
- dbout(cct, 20)<<"Null value for blob index(" \
- <<index<<") in stmt("<<stmt<<") "<< dbendl; \
+ ldpp_dout(dpp, 20)<<"Null value for blob index(" \
+ <<index<<") in stmt("<<stmt<<") "<< dendl; \
} \
}while(0);
-#define SQL_DECODE_BLOB_PARAM(cct, stmt, index, param, sdb) \
+#define SQL_DECODE_BLOB_PARAM(dpp, stmt, index, param, sdb) \
do { \
bufferlist b; \
void *blob; \
int blob_len = 0; \
\
- SQL_READ_BLOB(cct, stmt, index, blob, blob_len); \
+ SQL_READ_BLOB(dpp, stmt, index, blob, blob_len); \
\
b.append(reinterpret_cast<char *>(blob), blob_len); \
\
decode(param, b); \
}while(0);
-#define SQL_EXECUTE(params, stmt, cbk, args...) \
+#define SQL_EXECUTE(dpp, params, stmt, cbk, args...) \
do{ \
if (!stmt) { \
- ret = Prepare(params); \
+ ret = Prepare(dpp, params); \
} \
\
if (!stmt) { \
- dbout(cct, 0) <<"No prepared statement "<< dbendl; \
+ ldpp_dout(dpp, 0) <<"No prepared statement "<< dendl; \
goto out; \
} \
\
- ret = Bind(params); \
+ ret = Bind(dpp, params); \
if (ret) { \
- dbout(cct, 0) <<"Bind parameters failed for stmt(" <<stmt<<") "<< dbendl; \
+ ldpp_dout(dpp, 0) <<"Bind parameters failed for stmt(" <<stmt<<") "<< dendl; \
goto out; \
} \
\
- ret = Step(params->op, stmt, cbk); \
+ ret = Step(dpp, params->op, stmt, cbk); \
\
- Reset(stmt); \
+ Reset(dpp, stmt); \
\
if (ret) { \
- dbout(cct, 0) <<"Execution failed for stmt(" <<stmt<<")"<< dbendl; \
+ ldpp_dout(dpp, 0) <<"Execution failed for stmt(" <<stmt<<")"<< dendl; \
goto out; \
} \
}while(0);
Bucket_User_NS
};
-static int list_user(CephContext *cct, DBOpInfo &op, sqlite3_stmt *stmt) {
+static int list_user(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt) {
if (!stmt)
return -1;
- //cout<<sqlite3_column_text(stmt, 0) << dbendl;
+ //cout<<sqlite3_column_text(stmt, 0) << dendl;
/* Ensure the column names match with the user table defined in dbstore.h
UserID TEXT , \ - 0
Tenant TEXT , \ - 1
op.user.uinfo.display_name = (const char*)sqlite3_column_text(stmt, DisplayName); // user_name
op.user.uinfo.user_email = (const char*)sqlite3_column_text(stmt, UserEmail);
- SQL_DECODE_BLOB_PARAM(cct, stmt, AccessKeys, op.user.uinfo.access_keys, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, SwiftKeys, op.user.uinfo.swift_keys, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, SubUsers, op.user.uinfo.subusers, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, AccessKeys, op.user.uinfo.access_keys, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, SwiftKeys, op.user.uinfo.swift_keys, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, SubUsers, op.user.uinfo.subusers, sdb);
op.user.uinfo.suspended = sqlite3_column_int(stmt, Suspended);
op.user.uinfo.max_buckets = sqlite3_column_int(stmt, MaxBuckets);
op.user.uinfo.op_mask = sqlite3_column_int(stmt, OpMask);
- SQL_DECODE_BLOB_PARAM(cct, stmt, UserCaps, op.user.uinfo.caps, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, UserCaps, op.user.uinfo.caps, sdb);
op.user.uinfo.admin = sqlite3_column_int(stmt, Admin);
op.user.uinfo.system = sqlite3_column_int(stmt, System);
op.user.uinfo.default_placement.storage_class = (const char*)sqlite3_column_text(stmt, PlacementStorageClass);
- SQL_DECODE_BLOB_PARAM(cct, stmt, PlacementTags, op.user.uinfo.placement_tags, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, PlacementTags, op.user.uinfo.placement_tags, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, BucketQuota, op.user.uinfo.bucket_quota, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, TempURLKeys, op.user.uinfo.temp_url_keys, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, UserQuota, op.user.uinfo.user_quota, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, BucketQuota, op.user.uinfo.bucket_quota, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, TempURLKeys, op.user.uinfo.temp_url_keys, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, UserQuota, op.user.uinfo.user_quota, sdb);
op.user.uinfo.type = sqlite3_column_int(stmt, TYPE);
- SQL_DECODE_BLOB_PARAM(cct, stmt, MfaIDs, op.user.uinfo.mfa_ids, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, MfaIDs, op.user.uinfo.mfa_ids, sdb);
op.user.uinfo.assumed_role_arn = (const char*)sqlite3_column_text(stmt, AssumedRoleARN);
- SQL_DECODE_BLOB_PARAM(cct, stmt, UserAttrs, op.user.user_attrs, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, UserAttrs, op.user.user_attrs, sdb);
op.user.user_version.ver = sqlite3_column_int(stmt, UserVersion);
op.user.user_version.tag = (const char*)sqlite3_column_text(stmt, UserVersionTag);
return 0;
}
-static int list_bucket(CephContext *cct, DBOpInfo &op, sqlite3_stmt *stmt) {
+static int list_bucket(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt) {
if (!stmt)
return -1;
// cout<<sqlite3_column_text(stmt, 0)<<", ";
- // cout<<sqlite3_column_text(stmt, 1) << dbendl;
+ // cout<<sqlite3_column_text(stmt, 1) << dendl;
op.bucket.ent.bucket.name = (const char*)sqlite3_column_text(stmt, BucketName);
op.bucket.ent.bucket.tenant = (const char*)sqlite3_column_text(stmt, Bucket_Tenant);
op.bucket.ent.bucket.bucket_id = (const char*)sqlite3_column_text(stmt, BucketID);
op.bucket.ent.size = sqlite3_column_int(stmt, Size);
op.bucket.ent.size_rounded = sqlite3_column_int(stmt, SizeRounded);
- SQL_DECODE_BLOB_PARAM(cct, stmt, CreationTime, op.bucket.ent.creation_time, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, CreationTime, op.bucket.ent.creation_time, sdb);
op.bucket.ent.count = sqlite3_column_int(stmt, Count);
op.bucket.ent.placement_rule.name = (const char*)sqlite3_column_text(stmt, Bucket_PlacementName);
op.bucket.ent.placement_rule.storage_class = (const char*)sqlite3_column_text(stmt, Bucket_PlacementStorageClass);
op.bucket.info.zonegroup = (const char*)sqlite3_column_text(stmt, Zonegroup);
op.bucket.info.has_instance_obj = sqlite3_column_int(stmt, HasInstanceObj);
- SQL_DECODE_BLOB_PARAM(cct, stmt, Quota, op.bucket.info.quota, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, Quota, op.bucket.info.quota, sdb);
op.bucket.info.requester_pays = sqlite3_column_int(stmt, RequesterPays);
op.bucket.info.has_website = sqlite3_column_int(stmt, HasWebsite);
- SQL_DECODE_BLOB_PARAM(cct, stmt, WebsiteConf, op.bucket.info.website_conf, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, WebsiteConf, op.bucket.info.website_conf, sdb);
op.bucket.info.swift_versioning = sqlite3_column_int(stmt, SwiftVersioning);
op.bucket.info.swift_ver_location = (const char*)sqlite3_column_text(stmt, SwiftVerLocation);
- SQL_DECODE_BLOB_PARAM(cct, stmt, MdsearchConfig, op.bucket.info.mdsearch_config, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, MdsearchConfig, op.bucket.info.mdsearch_config, sdb);
op.bucket.info.new_bucket_instance_id = (const char*)sqlite3_column_text(stmt, NewBucketInstanceID);
- SQL_DECODE_BLOB_PARAM(cct, stmt, ObjectLock, op.bucket.info.obj_lock, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, SyncPolicyInfoGroups, op.bucket.info.sync_policy, sdb);
- SQL_DECODE_BLOB_PARAM(cct, stmt, BucketAttrs, op.bucket.bucket_attrs, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, ObjectLock, op.bucket.info.obj_lock, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, SyncPolicyInfoGroups, op.bucket.info.sync_policy, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, BucketAttrs, op.bucket.bucket_attrs, sdb);
op.bucket.bucket_version.ver = sqlite3_column_int(stmt, BucketVersion);
op.bucket.bucket_version.tag = (const char*)sqlite3_column_text(stmt, BucketVersionTag);
op.bucket.info.objv_tracker.read_version = op.bucket.bucket_version;
op.bucket.info.objv_tracker.write_version = op.bucket.bucket_version;
- SQL_DECODE_BLOB_PARAM(cct, stmt, Mtime, op.bucket.mtime, sdb);
+ SQL_DECODE_BLOB_PARAM(dpp, stmt, Mtime, op.bucket.mtime, sdb);
op.bucket.list_entries.push_back(op.bucket.ent);
return 0;
}
-static int list_object(CephContext *cct, DBOpInfo &op, sqlite3_stmt *stmt) {
+static int list_object(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt) {
if (!stmt)
return -1;
// cout<<sqlite3_column_text(stmt, 0)<<", ";
- // cout<<sqlite3_column_text(stmt, 1) << dbendl;
+ // cout<<sqlite3_column_text(stmt, 1) << dendl;
return 0;
}
-static int get_objectdata(CephContext *cct, DBOpInfo &op, sqlite3_stmt *stmt) {
+static int get_objectdata(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt) {
if (!stmt)
return -1;
if (blob)
strncpy(data, (const char *)blob, datalen);
-// cout<<data<<","<<datalen << dbendl;
+// cout<<data<<","<<datalen << dendl;
return 0;
}
-int SQLiteDB::InitializeDBOps()
+int SQLiteDB::InitializeDBOps(const DoutPrefixProvider *dpp)
{
- (void)createTables();
+ (void)createTables(dpp);
dbops.InsertUser = new SQLInsertUser(&this->db, cct);
dbops.RemoveUser = new SQLRemoveUser(&this->db, cct);
dbops.GetUser = new SQLGetUser(&this->db, cct);
return 0;
}
-int SQLiteDB::FreeDBOps()
+int SQLiteDB::FreeDBOps(const DoutPrefixProvider *dpp)
{
delete dbops.InsertUser;
delete dbops.RemoveUser;
return 0;
}
-void *SQLiteDB::openDB()
+void *SQLiteDB::openDB(const DoutPrefixProvider *dpp)
{
string dbname;
int rc = 0;
dbname = getDBname();
if (dbname.empty()) {
- dbout(cct, 0)<<"dbname is NULL" << dbendl;
+ ldpp_dout(dpp, 0)<<"dbname is NULL" << dendl;
goto out;
}
NULL);
if (rc) {
- dbout(cct, 0) <<"Cant open "<<dbname<<"; Errmsg - "\
- <<sqlite3_errmsg((sqlite3*)db) << dbendl;
+ ldpp_dout(dpp, 0) <<"Cant open "<<dbname<<"; Errmsg - "\
+ <<sqlite3_errmsg((sqlite3*)db) << dendl;
} else {
- dbout(cct, 0) <<"Opened database("<<dbname<<") successfully" << dbendl;
+ ldpp_dout(dpp, 0) <<"Opened database("<<dbname<<") successfully" << dendl;
}
- exec("PRAGMA foreign_keys=ON", NULL);
+ exec(dpp, "PRAGMA foreign_keys=ON", NULL);
out:
return db;
}
-int SQLiteDB::closeDB()
+int SQLiteDB::closeDB(const DoutPrefixProvider *dpp)
{
if (db)
sqlite3_close((sqlite3 *)db);
return 0;
}
-int SQLiteDB::Reset(sqlite3_stmt *stmt)
+int SQLiteDB::Reset(const DoutPrefixProvider *dpp, sqlite3_stmt *stmt)
{
int ret = -1;
return ret;
}
-int SQLiteDB::Step(DBOpInfo &op, sqlite3_stmt *stmt,
- int (*cbk)(CephContext *cct, DBOpInfo &op, sqlite3_stmt *stmt))
+int SQLiteDB::Step(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt,
+ int (*cbk)(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt))
{
int ret = -1;
ret = sqlite3_step(stmt);
if ((ret != SQLITE_DONE) && (ret != SQLITE_ROW)) {
- dbout(cct, 0)<<"sqlite step failed for stmt("<<stmt \
- <<"); Errmsg - "<<sqlite3_errmsg((sqlite3*)db) << dbendl;
+ ldpp_dout(dpp, 0)<<"sqlite step failed for stmt("<<stmt \
+ <<"); Errmsg - "<<sqlite3_errmsg((sqlite3*)db) << dendl;
return -1;
} else if (ret == SQLITE_ROW) {
if (cbk) {
- (*cbk)(ctx(), op, stmt);
+ (*cbk)(dpp, op, stmt);
} else {
}
goto again;
}
- dbout(cct, 20)<<"sqlite step successfully executed for stmt(" \
- <<stmt<<") ret = " << ret << dbendl;
+ ldpp_dout(dpp, 20)<<"sqlite step successfully executed for stmt(" \
+ <<stmt<<") ret = " << ret << dendl;
return 0;
}
-int SQLiteDB::exec(const char *schema,
+int SQLiteDB::exec(const DoutPrefixProvider *dpp, const char *schema,
int (*callback)(void*,int,char**,char**))
{
int ret = -1;
ret = sqlite3_exec((sqlite3*)db, schema, callback, 0, &errmsg);
if (ret != SQLITE_OK) {
- dbout(cct, 0) <<"sqlite exec failed for schema("<<schema \
- <<"); Errmsg - "<<errmsg << dbendl;
+ ldpp_dout(dpp, 0) <<"sqlite exec failed for schema("<<schema \
+ <<"); Errmsg - "<<errmsg << dendl;
sqlite3_free(errmsg);
goto out;
}
ret = 0;
- dbout(cct, 10) <<"sqlite exec successfully processed for schema(" \
- <<schema<<")" << dbendl;
+ ldpp_dout(dpp, 10) <<"sqlite exec successfully processed for schema(" \
+ <<schema<<")" << dendl;
out:
return ret;
}
-int SQLiteDB::createTables()
+int SQLiteDB::createTables(const DoutPrefixProvider *dpp)
{
int ret = -1;
int cu, cb = -1;
params.user_table = getUserTable();
params.bucket_table = getBucketTable();
- if ((cu = createUserTable(¶ms)))
+ if ((cu = createUserTable(dpp, ¶ms)))
goto out;
- if ((cb = createBucketTable(¶ms)))
+ if ((cb = createBucketTable(dpp, ¶ms)))
goto out;
- if ((cb = createQuotaTable(¶ms)))
+ if ((cb = createQuotaTable(dpp, ¶ms)))
goto out;
ret = 0;
out:
if (ret) {
if (cu)
- DeleteUserTable(¶ms);
+ DeleteUserTable(dpp, ¶ms);
if (cb)
- DeleteBucketTable(¶ms);
- dbout(cct, 0)<<"Creation of tables failed" << dbendl;
+ DeleteBucketTable(dpp, ¶ms);
+ ldpp_dout(dpp, 0)<<"Creation of tables failed" << dendl;
}
return ret;
}
-int SQLiteDB::createUserTable(DBOpParams *params)
+int SQLiteDB::createUserTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = CreateTableSchema("User", params);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"CreateUserTable failed" << dbendl;
+ ldpp_dout(dpp, 0)<<"CreateUserTable failed" << dendl;
- dbout(cct, 20)<<"CreateUserTable suceeded" << dbendl;
+ ldpp_dout(dpp, 20)<<"CreateUserTable suceeded" << dendl;
return ret;
}
-int SQLiteDB::createBucketTable(DBOpParams *params)
+int SQLiteDB::createBucketTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = CreateTableSchema("Bucket", params);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"CreateBucketTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"CreateBucketTable failed " << dendl;
- dbout(cct, 20)<<"CreateBucketTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"CreateBucketTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::createObjectTable(DBOpParams *params)
+int SQLiteDB::createObjectTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = CreateTableSchema("Object", params);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"CreateObjectTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"CreateObjectTable failed " << dendl;
- dbout(cct, 20)<<"CreateObjectTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"CreateObjectTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::createQuotaTable(DBOpParams *params)
+int SQLiteDB::createQuotaTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = CreateTableSchema("Quota", params);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"CreateQuotaTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"CreateQuotaTable failed " << dendl;
- dbout(cct, 20)<<"CreateQuotaTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"CreateQuotaTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::createObjectDataTable(DBOpParams *params)
+int SQLiteDB::createObjectDataTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = CreateTableSchema("ObjectData", params);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"CreateObjectDataTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"CreateObjectDataTable failed " << dendl;
- dbout(cct, 20)<<"CreateObjectDataTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"CreateObjectDataTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::DeleteUserTable(DBOpParams *params)
+int SQLiteDB::DeleteUserTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = DeleteTableSchema(params->user_table);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"DeleteUserTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"DeleteUserTable failed " << dendl;
- dbout(cct, 20)<<"DeleteUserTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"DeleteUserTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::DeleteBucketTable(DBOpParams *params)
+int SQLiteDB::DeleteBucketTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = DeleteTableSchema(params->bucket_table);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"DeletebucketTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"DeletebucketTable failed " << dendl;
- dbout(cct, 20)<<"DeletebucketTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"DeletebucketTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::DeleteObjectTable(DBOpParams *params)
+int SQLiteDB::DeleteObjectTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = DeleteTableSchema(params->object_table);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"DeleteObjectTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"DeleteObjectTable failed " << dendl;
- dbout(cct, 20)<<"DeleteObjectTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"DeleteObjectTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::DeleteObjectDataTable(DBOpParams *params)
+int SQLiteDB::DeleteObjectDataTable(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = DeleteTableSchema(params->objectdata_table);
- ret = exec(schema.c_str(), NULL);
+ ret = exec(dpp, schema.c_str(), NULL);
if (ret)
- dbout(cct, 0)<<"DeleteObjectDataTable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"DeleteObjectDataTable failed " << dendl;
- dbout(cct, 20)<<"DeleteObjectDataTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"DeleteObjectDataTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::ListAllUsers(DBOpParams *params)
+int SQLiteDB::ListAllUsers(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = ListTableSchema(params->user_table);
- // cout<<"########### Listing all Users #############" << dbendl;
- ret = exec(schema.c_str(), &list_callback);
+ // cout<<"########### Listing all Users #############" << dendl;
+ ret = exec(dpp, schema.c_str(), &list_callback);
if (ret)
- dbout(cct, 0)<<"GetUsertable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"GetUsertable failed " << dendl;
- dbout(cct, 20)<<"GetUserTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"GetUserTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::ListAllBuckets(DBOpParams *params)
+int SQLiteDB::ListAllBuckets(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
schema = ListTableSchema(params->bucket_table);
-// cout<<"########### Listing all Buckets #############" << dbendl;
- ret = exec(schema.c_str(), &list_callback);
+// cout<<"########### Listing all Buckets #############" << dendl;
+ ret = exec(dpp, schema.c_str(), &list_callback);
if (ret)
- dbout(cct, 0)<<"Listbuckettable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"Listbuckettable failed " << dendl;
- dbout(cct, 20)<<"ListbucketTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"ListbucketTable suceeded " << dendl;
return ret;
}
-int SQLiteDB::ListAllObjects(DBOpParams *params)
+int SQLiteDB::ListAllObjects(const DoutPrefixProvider *dpp, DBOpParams *params)
{
int ret = -1;
string schema;
map<string, class ObjectOp*> objectmap;
string bucket;
- //cout<<"########### Listing all Objects #############" << dbendl;
+ //cout<<"########### Listing all Objects #############" << dendl;
objectmap = getObjectMap();
if (objectmap.empty())
- dbout(cct, 20)<<"objectmap empty " << dbendl;
+ ldpp_dout(dpp, 20)<<"objectmap empty " << dendl;
for (iter = objectmap.begin(); iter != objectmap.end(); ++iter) {
bucket = iter->first;
".object.table";
schema = ListTableSchema(params->object_table);
- ret = exec(schema.c_str(), &list_callback);
+ ret = exec(dpp, schema.c_str(), &list_callback);
if (ret)
- dbout(cct, 0)<<"ListObjecttable failed " << dbendl;
+ ldpp_dout(dpp, 0)<<"ListObjecttable failed " << dendl;
- dbout(cct, 20)<<"ListObjectTable suceeded " << dbendl;
+ ldpp_dout(dpp, 20)<<"ListObjectTable suceeded " << dendl;
}
return ret;
}
-int SQLObjectOp::InitializeObjectOps()
+int SQLObjectOp::InitializeObjectOps(const DoutPrefixProvider *dpp)
{
InsertObject = new SQLInsertObject(sdb, cct);
RemoveObject = new SQLRemoveObject(sdb, cct);
return 0;
}
-int SQLObjectOp::FreeObjectOps()
+int SQLObjectOp::FreeObjectOps(const DoutPrefixProvider *dpp)
{
delete InsertObject;
delete RemoveObject;
return 0;
}
-int SQLInsertUser::Prepare(struct DBOpParams *params)
+int SQLInsertUser::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLInsertUser - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLInsertUser - no db" << dendl;
goto out;
}
p_params.user_table = params->user_table;
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareInsertUser");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareInsertUser");
out:
return ret;
}
-int SQLInsertUser::Bind(struct DBOpParams *params)
+int SQLInsertUser::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.tenant.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.tenant.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.ns.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.ns.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.display_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.display_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.display_name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.display_name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_email.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_email.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_email.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_email.c_str(), sdb);
if (!params->op.user.uinfo.access_keys.empty()) {
string access_key;
access_key = k.id;
key = k.key;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.access_keys_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, access_key.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.access_keys_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, access_key.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.access_keys_secret.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, key.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.access_keys_secret.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, key.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.access_keys.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.access_keys, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.access_keys.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.access_keys, sdb);
}
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.swift_keys.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.swift_keys, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.swift_keys.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.swift_keys, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.subusers.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.subusers, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.subusers.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.subusers, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.suspended.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.suspended, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.suspended.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.suspended, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.max_buckets.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.max_buckets, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.max_buckets.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.max_buckets, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.op_mask.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.op_mask, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.op_mask.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.op_mask, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_caps.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.caps, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_caps.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.caps, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.admin.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.admin, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.admin.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.admin, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.system.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.system, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.system.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.system, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.placement_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.default_placement.name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.placement_name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.default_placement.name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.placement_storage_class.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.default_placement.storage_class.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.placement_storage_class.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.default_placement.storage_class.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.placement_tags.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.placement_tags, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.placement_tags.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.placement_tags, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.bucket_quota.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.bucket_quota, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.bucket_quota.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.bucket_quota, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.temp_url_keys.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.temp_url_keys, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.temp_url_keys.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.temp_url_keys, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_quota.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.user_quota, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_quota.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.user_quota, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.type.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.type, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.type.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.type, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.mfa_ids.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.mfa_ids, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.mfa_ids.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.mfa_ids, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.assumed_role_arn.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.assumed_role_arn.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.assumed_role_arn.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.assumed_role_arn.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_attrs.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.user_attrs, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_attrs.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.user_attrs, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_ver.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.user.user_version.ver, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_ver.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.user.user_version.ver, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_ver_tag.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.user_version.tag.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_ver_tag.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.user_version.tag.c_str(), sdb);
out:
return rc;
}
-int SQLInsertUser::Execute(struct DBOpParams *params)
+int SQLInsertUser::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLRemoveUser::Prepare(struct DBOpParams *params)
+int SQLRemoveUser::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLRemoveUser - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLRemoveUser - no db" << dendl;
goto out;
}
p_params.user_table = params->user_table;
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareRemoveUser");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareRemoveUser");
out:
return ret;
}
-int SQLRemoveUser::Bind(struct DBOpParams *params)
+int SQLRemoveUser::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
out:
return rc;
}
-int SQLRemoveUser::Execute(struct DBOpParams *params)
+int SQLRemoveUser::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLGetUser::Prepare(struct DBOpParams *params)
+int SQLGetUser::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLGetUser - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLGetUser - no db" << dendl;
goto out;
}
p_params.op.query_str = params->op.query_str;
if (params->op.query_str == "email") {
- SQL_PREPARE(ctx(), p_params, sdb, email_stmt, ret, "PrepareGetUser");
+ SQL_PREPARE(dpp, p_params, sdb, email_stmt, ret, "PrepareGetUser");
} else if (params->op.query_str == "access_key") {
- SQL_PREPARE(ctx(), p_params, sdb, ak_stmt, ret, "PrepareGetUser");
+ SQL_PREPARE(dpp, p_params, sdb, ak_stmt, ret, "PrepareGetUser");
} else if (params->op.query_str == "user_id") {
- SQL_PREPARE(ctx(), p_params, sdb, userid_stmt, ret, "PrepareGetUser");
+ SQL_PREPARE(dpp, p_params, sdb, userid_stmt, ret, "PrepareGetUser");
} else { // by default by userid
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareGetUser");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareGetUser");
}
out:
return ret;
}
-int SQLGetUser::Bind(struct DBOpParams *params)
+int SQLGetUser::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
if (params->op.query_str == "email") {
- SQL_BIND_INDEX(ctx(), email_stmt, index, p_params.op.user.user_email.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), email_stmt, index, params->op.user.uinfo.user_email.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, email_stmt, index, p_params.op.user.user_email.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, email_stmt, index, params->op.user.uinfo.user_email.c_str(), sdb);
} else if (params->op.query_str == "access_key") {
if (!params->op.user.uinfo.access_keys.empty()) {
string access_key;
const RGWAccessKey& k = it->second;
access_key = k.id;
- SQL_BIND_INDEX(ctx(), ak_stmt, index, p_params.op.user.access_keys_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), ak_stmt, index, access_key.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, ak_stmt, index, p_params.op.user.access_keys_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, ak_stmt, index, access_key.c_str(), sdb);
}
} else if (params->op.query_str == "user_id") {
- SQL_BIND_INDEX(ctx(), userid_stmt, index, p_params.op.user.tenant.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), userid_stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, userid_stmt, index, p_params.op.user.tenant.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, userid_stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), userid_stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), userid_stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, userid_stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, userid_stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), userid_stmt, index, p_params.op.user.ns.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), userid_stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, userid_stmt, index, p_params.op.user.ns.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, userid_stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb);
} else { // by default by userid
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
}
out:
return rc;
}
-int SQLGetUser::Execute(struct DBOpParams *params)
+int SQLGetUser::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
if (params->op.query_str == "email") {
- SQL_EXECUTE(params, email_stmt, list_user);
+ SQL_EXECUTE(dpp, params, email_stmt, list_user);
} else if (params->op.query_str == "access_key") {
- SQL_EXECUTE(params, ak_stmt, list_user);
+ SQL_EXECUTE(dpp, params, ak_stmt, list_user);
} else if (params->op.query_str == "user_id") {
- SQL_EXECUTE(params, userid_stmt, list_user);
+ SQL_EXECUTE(dpp, params, userid_stmt, list_user);
} else { // by default by userid
- SQL_EXECUTE(params, stmt, list_user);
+ SQL_EXECUTE(dpp, params, stmt, list_user);
}
out:
return ret;
}
-int SQLInsertBucket::Prepare(struct DBOpParams *params)
+int SQLInsertBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLInsertBucket - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLInsertBucket - no db" << dendl;
goto out;
}
p_params.bucket_table = params->bucket_table;
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareInsertBucket");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareInsertBucket");
out:
return ret;
}
-int SQLInsertBucket::Bind(struct DBOpParams *params)
+int SQLInsertBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.tenant.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.tenant.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.marker.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.marker.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.size.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.ent.size, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.size.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.ent.size, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.size_rounded.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.ent.size_rounded, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.size_rounded.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.ent.size_rounded, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.creation_time.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.creation_time, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.creation_time.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.creation_time, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.count.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.ent.count, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.count.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.ent.count, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.placement_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.placement_name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.flags.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.flags, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.flags.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.flags, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.has_instance_obj, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.has_instance_obj, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.quota.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.quota, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.quota.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.quota, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.requester_pays, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.requester_pays, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.has_website.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.has_website, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.has_website.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.has_website, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.website_conf.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.website_conf, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.website_conf.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.website_conf, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.swift_versioning, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.swift_versioning, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.mdsearch_config, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.mdsearch_config, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.obj_lock, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.obj_lock, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.sync_policy, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.sync_policy, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.bucket_attrs, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.bucket_attrs, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.bucket_version.ver, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.bucket.bucket_version.ver, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_ver_tag.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.bucket_version.tag.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_ver_tag.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.bucket_version.tag.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.mtime.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.mtime, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.mtime.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.mtime, sdb);
out:
return rc;
}
-int SQLInsertBucket::Execute(struct DBOpParams *params)
+int SQLInsertBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
class SQLObjectOp *ObPtr = NULL;
ObPtr = new SQLObjectOp(sdb, ctx());
- objectmapInsert(bucket_name, ObPtr);
+ objectmapInsert(dpp, bucket_name, ObPtr);
params->object_table = bucket_name + ".object.table";
- (void)createObjectTable(params);
+ (void)createObjectTable(dpp, params);
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLUpdateBucket::Prepare(struct DBOpParams *params)
+int SQLUpdateBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLUpdateBucket - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLUpdateBucket - no db" << dendl;
goto out;
}
p_params.bucket_table = params->bucket_table;
if (params->op.query_str == "attrs") {
- SQL_PREPARE(ctx(), p_params, sdb, attrs_stmt, ret, "PrepareUpdateBucket");
+ SQL_PREPARE(dpp, p_params, sdb, attrs_stmt, ret, "PrepareUpdateBucket");
} else if (params->op.query_str == "owner") {
- SQL_PREPARE(ctx(), p_params, sdb, owner_stmt, ret, "PrepareUpdateBucket");
+ SQL_PREPARE(dpp, p_params, sdb, owner_stmt, ret, "PrepareUpdateBucket");
} else if (params->op.query_str == "info") {
- SQL_PREPARE(ctx(), p_params, sdb, info_stmt, ret, "PrepareUpdateBucket");
+ SQL_PREPARE(dpp, p_params, sdb, info_stmt, ret, "PrepareUpdateBucket");
} else {
- dbout(cct, 0)<<"In SQLUpdateBucket invalid query_str:" <<
- params->op.query_str << "" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLUpdateBucket invalid query_str:" <<
+ params->op.query_str << "" << dendl;
goto out;
}
return ret;
}
-int SQLUpdateBucket::Bind(struct DBOpParams *params)
+int SQLUpdateBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
} else if (params->op.query_str == "info") {
stmt = &info_stmt;
} else {
- dbout(cct, 0)<<"In SQLUpdateBucket invalid query_str:" <<
- params->op.query_str << "" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLUpdateBucket invalid query_str:" <<
+ params->op.query_str << "" << dendl;
goto out;
}
if (params->op.query_str == "attrs") {
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.bucket_attrs, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.bucket_attrs, sdb);
} else if (params->op.query_str == "owner") {
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.creation_time, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.creation_time, sdb);
} else if (params->op.query_str == "info") {
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.tenant.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.tenant.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.marker.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.marker.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.creation_time, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.creation_time, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.count.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.ent.count, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.count.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.ent.count, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.placement_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.placement_name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.flags.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.flags, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.flags.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.flags, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.has_instance_obj, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.has_instance_obj, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.quota.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.quota, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.quota.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.quota, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.requester_pays, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.requester_pays, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.has_website.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.has_website, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.has_website.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.has_website, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.website_conf.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.website_conf, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.website_conf.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.website_conf, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.swift_versioning, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.swift_versioning, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.mdsearch_config, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.mdsearch_config, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.obj_lock, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.obj_lock, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.sync_policy, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.sync_policy, sdb);
}
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb);
- SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.bucket_version.ver, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb);
+ SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.bucket_version.ver, sdb);
- SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.mtime.c_str(), sdb);
- SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.mtime, sdb);
+ SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.mtime.c_str(), sdb);
+ SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.mtime, sdb);
out:
return rc;
}
-int SQLUpdateBucket::Execute(struct DBOpParams *params)
+int SQLUpdateBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
sqlite3_stmt** stmt = NULL; // Prepared statement
} else if (params->op.query_str == "info") {
stmt = &info_stmt;
} else {
- dbout(cct, 0)<<"In SQLUpdateBucket invalid query_str:" <<
- params->op.query_str << "" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLUpdateBucket invalid query_str:" <<
+ params->op.query_str << "" << dendl;
goto out;
}
- SQL_EXECUTE(params, *stmt, NULL);
+ SQL_EXECUTE(dpp, params, *stmt, NULL);
out:
return ret;
}
-int SQLRemoveBucket::Prepare(struct DBOpParams *params)
+int SQLRemoveBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLRemoveBucket - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLRemoveBucket - no db" << dendl;
goto out;
}
p_params.bucket_table = params->bucket_table;
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareRemoveBucket");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareRemoveBucket");
out:
return ret;
}
-int SQLRemoveBucket::Bind(struct DBOpParams *params)
+int SQLRemoveBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLRemoveBucket::Execute(struct DBOpParams *params)
+int SQLRemoveBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- objectmapDelete(params->op.bucket.info.bucket.name);
+ objectmapDelete(dpp, params->op.bucket.info.bucket.name);
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLGetBucket::Prepare(struct DBOpParams *params)
+int SQLGetBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLGetBucket - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLGetBucket - no db" << dendl;
goto out;
}
p_params.bucket_table = params->bucket_table;
p_params.user_table = params->user_table;
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareGetBucket");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareGetBucket");
out:
return ret;
}
-int SQLGetBucket::Bind(struct DBOpParams *params)
+int SQLGetBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLGetBucket::Execute(struct DBOpParams *params)
+int SQLGetBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
params->op.name = "GetBucket";
- SQL_EXECUTE(params, stmt, list_bucket);
+ SQL_EXECUTE(dpp, params, stmt, list_bucket);
out:
return ret;
}
-int SQLListUserBuckets::Prepare(struct DBOpParams *params)
+int SQLListUserBuckets::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLListUserBuckets - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLListUserBuckets - no db" << dendl;
goto out;
}
p_params.bucket_table = params->bucket_table;
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareListUserBuckets");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareListUserBuckets");
out:
return ret;
}
-int SQLListUserBuckets::Bind(struct DBOpParams *params)
+int SQLListUserBuckets::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.min_marker.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.min_marker.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.min_marker.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.min_marker.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.list_max_count.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->op.list_max_count, sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.list_max_count.c_str(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->op.list_max_count, sdb);
out:
return rc;
}
-int SQLListUserBuckets::Execute(struct DBOpParams *params)
+int SQLListUserBuckets::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, list_bucket);
+ SQL_EXECUTE(dpp, params, stmt, list_bucket);
out:
return ret;
}
-int SQLInsertObject::Prepare(struct DBOpParams *params)
+int SQLInsertObject::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
string bucket_name;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLInsertObject - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLInsertObject - no db" << dendl;
goto out;
}
bucket_name = params->op.bucket.info.bucket.name;
p_params.object_table = bucket_name + ".object.table";
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareInsertObject");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareInsertObject");
out:
return ret;
}
-int SQLInsertObject::Bind(struct DBOpParams *params)
+int SQLInsertObject::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLInsertObject::Execute(struct DBOpParams *params)
+int SQLInsertObject::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLRemoveObject::Prepare(struct DBOpParams *params)
+int SQLRemoveObject::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
string bucket_name;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLRemoveObject - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLRemoveObject - no db" << dendl;
goto out;
}
p_params.object_table = bucket_name + ".object.table";
copy.object_table = bucket_name + ".object.table";
- (void)createObjectTable(©);
+ (void)createObjectTable(dpp, ©);
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareRemoveObject");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareRemoveObject");
out:
return ret;
}
-int SQLRemoveObject::Bind(struct DBOpParams *params)
+int SQLRemoveObject::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLRemoveObject::Execute(struct DBOpParams *params)
+int SQLRemoveObject::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLListObject::Prepare(struct DBOpParams *params)
+int SQLListObject::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
string bucket_name;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLListObject - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLListObject - no db" << dendl;
goto out;
}
p_params.object_table = bucket_name + ".object.table";
copy.object_table = bucket_name + ".object.table";
- (void)createObjectTable(©);
+ (void)createObjectTable(dpp, ©);
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareListObject");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareListObject");
out:
return ret;
}
-int SQLListObject::Bind(struct DBOpParams *params)
+int SQLListObject::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLListObject::Execute(struct DBOpParams *params)
+int SQLListObject::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, list_object);
+ SQL_EXECUTE(dpp, params, stmt, list_object);
out:
return ret;
}
-int SQLPutObjectData::Prepare(struct DBOpParams *params)
+int SQLPutObjectData::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
string bucket_name;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLPutObjectData - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLPutObjectData - no db" << dendl;
goto out;
}
copy.object_table = bucket_name + ".object.table";
copy.objectdata_table = bucket_name + ".objectdata.table";
- (void)createObjectDataTable(©);
+ (void)createObjectDataTable(dpp, ©);
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PreparePutObjectData");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PreparePutObjectData");
out:
return ret;
}
-int SQLPutObjectData::Bind(struct DBOpParams *params)
+int SQLPutObjectData::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.offset.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.offset.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, 3, params->offset, sdb);
+ SQL_BIND_INT(dpp, stmt, 3, params->offset, sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.data.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.data.c_str(), sdb);
- SQL_BIND_BLOB(ctx(), stmt, index, params->data.c_str(), params->data.length(), sdb);
+ SQL_BIND_BLOB(dpp, stmt, index, params->data.c_str(), params->data.length(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.datalen.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.datalen.c_str(), sdb);
- SQL_BIND_INT(ctx(), stmt, index, params->data.length(), sdb);
+ SQL_BIND_INT(dpp, stmt, index, params->data.length(), sdb);
out:
return rc;
}
-int SQLPutObjectData::Execute(struct DBOpParams *params)
+int SQLPutObjectData::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}
-int SQLGetObjectData::Prepare(struct DBOpParams *params)
+int SQLGetObjectData::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
string bucket_name;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLGetObjectData - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLGetObjectData - no db" << dendl;
goto out;
}
copy.object_table = bucket_name + ".object.table";
copy.objectdata_table = bucket_name + ".objectdata.table";
- (void)createObjectDataTable(©);
+ (void)createObjectDataTable(dpp, ©);
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareGetObjectData");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareGetObjectData");
out:
return ret;
}
-int SQLGetObjectData::Bind(struct DBOpParams *params)
+int SQLGetObjectData::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLGetObjectData::Execute(struct DBOpParams *params)
+int SQLGetObjectData::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, get_objectdata);
+ SQL_EXECUTE(dpp, params, stmt, get_objectdata);
out:
return ret;
}
-int SQLDeleteObjectData::Prepare(struct DBOpParams *params)
+int SQLDeleteObjectData::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
struct DBOpPrepareParams p_params = PrepareParams;
string bucket_name;
if (!*sdb) {
- dbout(cct, 0)<<"In SQLDeleteObjectData - no db" << dbendl;
+ ldpp_dout(dpp, 0)<<"In SQLDeleteObjectData - no db" << dendl;
goto out;
}
copy.object_table = bucket_name + ".object.table";
copy.objectdata_table = bucket_name + ".objectdata.table";
- (void)createObjectDataTable(©);
+ (void)createObjectDataTable(dpp, ©);
- SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareDeleteObjectData");
+ SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareDeleteObjectData");
out:
return ret;
}
-int SQLDeleteObjectData::Bind(struct DBOpParams *params)
+int SQLDeleteObjectData::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int index = -1;
int rc = 0;
struct DBOpPrepareParams p_params = PrepareParams;
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb);
- SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
+ SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb);
- SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
+ SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb);
out:
return rc;
}
-int SQLDeleteObjectData::Execute(struct DBOpParams *params)
+int SQLDeleteObjectData::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params)
{
int ret = -1;
- SQL_EXECUTE(params, stmt, NULL);
+ SQL_EXECUTE(dpp, params, stmt, NULL);
out:
return ret;
}