Method queryUnsafe

Source/Basic/Database.cpp:223–252

}

DB::Rows DB::queryUnsafe(SQLite::Database* db, String sql, const std::vector<Own<Value>>& args, bool withColumns) {
	Rows result;
	SQLite::Statement statement(*db, sql.toString());
	bindValues(statement, args);
	bool columnCollected = false;
	while (statement.executeStep()) {
		int colCount = statement.getColumnCount();
		if (!columnCollected && withColumns) {
			columnCollected = true;
			auto& values = result.emplace_back(colCount);
			for (int i = 0; i < colCount; i++) {
				values[i] = std::string(statement.getColumn(i).getName());
			}
		}
		auto& values = result.emplace_back(colCount);
		for (int i = 0; i < colCount; i++) {
			auto col = statement.getColumn(i);
			if (col.isInteger()) {
				values[i] = col.getInt64();
			} else if (col.isFloat()) {
				values[i] = col.getDouble();
			} else if (col.isText() || col.isBlob()) {
				values[i] = std::string(col.getText());
			} else if (col.isNull()) {
				values[i] = false;
			}
		}
	}
	return result;
}

void DB::insertUnsafe(SQLite::Database* db, String tableName, const std::deque<std::vector<Own<Value>>>& rows) {
	if (rows.empty() || rows.front().empty()) return;