| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | prepared_stmt.cpp | 21 : opCode_(opCode), sql_(sql), bindArgs_(bindArgs) {} in PreparedStmt()
31 sql_ = std::move(sql); in SetSql()
46 return sql_; in GetSql()
56 return opCode_ == ExecutorOperation::QUERY && !sql_.empty() && bindArgs_.size() <= DBConstant::MAX_SQL_ARGS_COUNT; in IsValid()
63 Parcel::GetStringLen(sql_) + // sql_ in CalcLength()
84 (void)parcel.WriteString(sql_); in Serialize()
125 (void)parcel.ReadString(sql_); in DeSerialize()
|
| H A D | table_info.cpp | 269 return sql_; in GetCreateTableSql()
274 sql_ = sql; in SetCreateTableSql()
275 for (auto &c : sql_) { in SetCreateTableSql()
278 if (DBCommon::HasConstraint(DBCommon::TrimSpace(sql_), "AUTOINCREMENT", " ", " ,)")) { in SetCreateTableSql()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | step_result_set.cpp | 35 : AbsResultSet(safe), conn_(std::move(conn)), sql_(sql), args_(args) in StepResultSet()
66 totalCost, acquireCost, prepareCost, countCost, rowCount_, SqliteUtils::Anonymous(sql_).c_str()); in StepResultSet()
90 auto type = SqliteUtils::GetSqlStatementType(sql_); in PrepareStep()
92 LOG_ERROR("invalid sql_ %{public}s!", SqliteUtils::Anonymous(sql_).c_str()); in PrepareStep()
97 auto [errCode, statement] = conn_->CreateStatement(sql_, conn_); in PrepareStep()
104 LOG_ERROR("failed, %{public}s is not query sql!", SqliteUtils::Anonymous(sql_).c_str()); in PrepareStep()
272 auto sql = std::move(sql_); in Close()
|
| H A D | rd_statement.cpp | 110 sql_ = newSql; in Prepare()
122 sql_ = newSql; in Prepare()
125 if (sql_.compare(newSql) == 0) { in Prepare()
141 sql_ = newSql; in Prepare()
170 sql_ = ""; in Finalize()
336 if (!readOnly_ && strcmp(sql_.c_str(), GlobalExpr::PRAGMA_VERSION) == 0) { in Execute()
357 if (readOnly_ && strcmp(sql_.c_str(), GlobalExpr::PRAGMA_VERSION) == 0) { in ExecuteForValue()
|
| H A D | sqlite_statement.cpp | 49 SqliteStatement::SqliteStatement() : readOnly_(false), columnCount_(0), numParameters_(0), stmt_(nullptr), sql_("") in SqliteStatement()
65 if (sql_.compare(newSql) == 0) { in Prepare()
88 sql_ = newSql; in Prepare()
170 LOG_ERROR("Bind has error: %{public}d, sql: %{public}s, errno %{public}d", errCode, sql_.c_str(), errno); in BindArgs()
236 sql_.c_str()); in Bind()
274 LOG_WARN("locked, retry=%{public}d, sql=%{public}s", retry, sql_.c_str()); in Count()
303 PrintInfoForDbError(ret, sql_); in InnerStep()
357 sql_.c_str()); in Execute()
367 int sqlType = SqliteUtils::GetSqlStatementType(sql_); in Execute()
380 LOG_ERROR("sqlite3_step failed %{public}d, sql is %{public}s, errno %{public}d", errCode, sql_ in Execute()
[all...] |
| H A D | rdb_sql_statistic.cpp | 82 execInfo_->sql_.emplace_back(sql); in SqlStatistic()
121 if (execInfo->sql_.empty()) { in Release()
|
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_store_subscribe_test.cpp | 614 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 1); }); in HWTEST_F()
615 observer2->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 1); }); in HWTEST_F()
644 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 1); }); in HWTEST_F()
662 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 1); }); in HWTEST_F()
687 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 1); }); in HWTEST_F()
722 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 3); }); in HWTEST_F()
748 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 2); }); in HWTEST_F()
768 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_.size(), 2); }); in HWTEST_F()
788 sqlObserver_->Callback([](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_[0], "PRAGMA quick_check"); }); in HWTEST_F()
808 sqlObserver_->Callback([value](SqlObserver::SqlExecutionInfo &info) { ASSERT_EQ(info.sql_[ in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/ |
| H A D | prepared_stmt.h | 50 std::string sql_; member in DistributedDB::PreparedStmt
|
| H A D | table_info.h | 148 std::string sql_; member in DistributedDB::TableInfo
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | step_result_set.h | 67 std::string sql_;
member in OHOS::NativeRdb::StepResultSet
|
| H A D | rd_statement.h | 66 std::string sql_ = ""; member in OHOS::NativeRdb::final
|
| H A D | sqlite_statement.h | 107 std::string sql_;
member in OHOS::NativeRdb::SqliteStatement
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_query.h | 108 std::string sql_; member in OHOS::DistributedRdb::RdbQuery
|
| H A D | rdb_query.cpp | 37 sql_ = sql; in MakeRemoteQuery()
104 return { sql_, bindArgs }; in GetRemoteCondition()
|
| /foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
| H A D | rdb_types.h | 311 std::vector<std::string> sql_; member
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_js_utils.cpp | 201 DECLARE_JS_PROPERTY(env, "sql", value.sql_), in Convert2JSValue()
|