virtual ~DBOp() {}
std::mutex mtx; // to protect prepared stmt
- std::string CreateTableSchema(std::string_view type,
- const DBOpParams *params) {
+ static std::string CreateTableSchema(std::string_view type,
+ const DBOpParams *params) {
if (!type.compare("User"))
return fmt::format(CreateUserTableQ,
params->user_table);
ceph_abort_msgf("incorrect table type %.*s", type.size(), type.data());
}
- std::string DeleteTableSchema(std::string_view table) {
+ static std::string DeleteTableSchema(std::string_view table) {
return fmt::format(DropQ, table);
}
- std::string ListTableSchema(std::string_view table) {
+ static std::string ListTableSchema(std::string_view table) {
return fmt::format(ListAllQ, table);
}
public:
virtual ~InsertUserOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.user_table,
params.op.user.user_id, params.op.user.tenant, params.op.user.ns,
params.op.user.display_name, params.op.user.user_email,
public:
virtual ~RemoveUserOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.user_table,
params.op.user.user_id);
}
public:
virtual ~GetUserOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
if (params.op.query_str == "email") {
return fmt::format(QueryByEmail, params.user_table,
params.op.user.user_email);
public:
virtual ~InsertBucketOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.bucket_table,
params.op.bucket.bucket_name, params.op.bucket.tenant,
params.op.bucket.marker, params.op.bucket.bucket_id,
public:
virtual ~UpdateBucketOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
if (params.op.query_str == "info") {
return fmt::format(InfoQuery, params.bucket_table,
params.op.bucket.tenant, params.op.bucket.marker, params.op.bucket.bucket_id,
public:
virtual ~RemoveBucketOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.bucket_table,
params.op.bucket.bucket_name);
}
public:
virtual ~GetBucketOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
//return fmt::format(Query, params.op.bucket.bucket_name,
// params.bucket_table, params.user_table);
return fmt::format(Query,
public:
virtual ~ListUserBucketsOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
if (params.op.query_str == "all") {
return fmt::format(AllQuery, params.bucket_table,
params.op.bucket.min_marker,
public:
virtual ~PutObjectOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.object_table, params.op.obj.obj_name,
params.op.obj.obj_instance, params.op.obj.obj_ns,
public:
virtual ~DeleteObjectOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.object_table,
params.op.bucket.bucket_name,
params.op.obj.obj_name,
public:
virtual ~GetObjectOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.object_table,
params.op.bucket.bucket_name,
public:
virtual ~ListBucketObjectsOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
/* XXX: Include obj_id, delim */
return fmt::format(Query,
params.object_table,
public:
virtual ~UpdateObjectOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
if (params.op.query_str == "omap") {
return fmt::format(OmapQuery,
params.object_table, params.op.obj.omap,
public:
virtual ~PutObjectDataOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.objectdata_table,
params.op.obj.obj_name, params.op.obj.obj_instance,
public:
virtual ~UpdateObjectDataOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.objectdata_table,
params.op.obj.mtime,
public:
virtual ~GetObjectDataOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.objectdata_table,
params.op.bucket.bucket_name,
public:
virtual ~DeleteObjectDataOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.objectdata_table,
params.op.bucket.bucket_name,
public:
virtual ~DeleteStaleObjectDataOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query,
params.objectdata_table,
params.objectdata_table,
public:
virtual ~InsertLCEntryOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.lc_entry_table,
params.op.lc_entry.index, params.op.lc_entry.bucket_name,
params.op.lc_entry.start_time, params.op.lc_entry.status);
public:
virtual ~RemoveLCEntryOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.lc_entry_table,
params.op.lc_entry.index, params.op.lc_entry.bucket_name);
}
public:
virtual ~GetLCEntryOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
if (params.op.query_str == "get_next_entry") {
return fmt::format(NextQuery, params.lc_entry_table,
params.op.lc_entry.index, params.op.lc_entry.bucket_name);
public:
virtual ~ListLCEntriesOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.lc_entry_table,
params.op.lc_entry.index, params.op.lc_entry.min_marker,
params.op.list_max_count);
public:
virtual ~InsertLCHeadOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.lc_head_table,
params.op.lc_head.index, params.op.lc_head.marker,
params.op.lc_head.start_date);
public:
virtual ~RemoveLCHeadOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.lc_head_table,
params.op.lc_head.index);
}
public:
virtual ~GetLCHeadOp() {}
- std::string Schema(DBOpPrepareParams ¶ms) {
+ static std::string Schema(DBOpPrepareParams ¶ms) {
return fmt::format(Query, params.lc_head_table,
params.op.lc_head.index);
}