MCPcopy Create free account
hub / github.com/alibaba/zvec / bind_dml_methods

Method bind_dml_methods

src/binding/python/model/python_collection.cc:203–250  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

201}
202
203void ZVecPyCollection::bind_dml_methods(
204 py::class_<Collection, Collection::Ptr> &col) {
205 // bind collection upsert/insert/update/delete methods
206 col.def("Insert",
207 [](Collection &self, std::vector<Doc> &docs) {
208 Result<WriteResults> result;
209 {
210 py::gil_scoped_release release;
211 result = self.Insert(docs);
212 }
213 return unwrap_expected(result);
214 })
215 .def("Update",
216 [](Collection &self, std::vector<Doc> &docs) {
217 Result<WriteResults> result;
218 {
219 py::gil_scoped_release release;
220 result = self.Update(docs);
221 }
222 return unwrap_expected(result);
223 })
224 .def("Upsert",
225 [](Collection &self, std::vector<Doc> &docs) {
226 Result<WriteResults> result;
227 {
228 py::gil_scoped_release release;
229 result = self.Upsert(docs);
230 }
231 return unwrap_expected(result);
232 })
233 .def("Delete",
234 [](Collection &self, const std::vector<std::string> &pks) {
235 Result<WriteResults> result;
236 {
237 py::gil_scoped_release release;
238 result = self.Delete(pks);
239 }
240 return unwrap_expected(result);
241 })
242 .def("DeleteByFilter", [](Collection &self, const std::string &filter) {
243 Status status;
244 {
245 py::gil_scoped_release release;
246 status = self.DeleteByFilter(filter);
247 }
248 throw_if_error(status);
249 });
250}
251
252void ZVecPyCollection::bind_dql_methods(
253 py::class_<Collection, Collection::Ptr> &col) {

Callers

nothing calls this directly

Calls 7

unwrap_expectedFunction · 0.85
throw_if_errorFunction · 0.85
DeleteByFilterMethod · 0.80
InsertMethod · 0.45
UpdateMethod · 0.45
UpsertMethod · 0.45
DeleteMethod · 0.45

Tested by

no test coverage detected