| 890 | |
| 891 | |
| 892 | int ops_sql_api_insert(struct db_url *url, struct sip_msg* msg, str *table, |
| 893 | str *cols) |
| 894 | { |
| 895 | cJSON *Jcols = NULL, *Jfilter; |
| 896 | int ret; |
| 897 | |
| 898 | ret = _parse_json_col_and_filter( cols, NULL, &Jcols, &Jfilter); |
| 899 | if (ret<0) { |
| 900 | LM_ERR("failed to JSON parse cols and filter\n"); |
| 901 | } else { |
| 902 | ret = sql_api_insert( url, msg, table, Jcols); |
| 903 | if (ret<0) { |
| 904 | LM_ERR("failed to perform DB insert query\n"); |
| 905 | } else { |
| 906 | ret =1; |
| 907 | } |
| 908 | } |
| 909 | |
| 910 | if (Jcols) cJSON_Delete(Jcols); |
| 911 | if (Jfilter) cJSON_Delete(Jfilter); |
| 912 | return ret; |
| 913 | } |
| 914 | |
| 915 | |
| 916 | int ops_sql_api_delete(struct db_url *url, struct sip_msg* msg, |
no test coverage detected