(self, omit_fields: set[str] | None = None)
| 2111 | return insert_query, insert_query_all |
| 2112 | |
| 2113 | def _make_queries(self, omit_fields: set[str] | None = None) -> tuple[str, str]: |
| 2114 | if omit_fields is None: |
| 2115 | omit_fields = set() |
| 2116 | |
| 2117 | if not (self._ignore_conflicts or self._update_fields) and not omit_fields: |
| 2118 | return self._executor.insert_query, self._executor.insert_query_all |
| 2119 | |
| 2120 | default_sql = self._build_default_values_sql() |
| 2121 | |
| 2122 | columns = self._filter_columns(omit_fields) |
| 2123 | if not columns: |
| 2124 | return default_sql, default_sql |
| 2125 | insert_query = self._executor._prepare_insert_statement( |
| 2126 | columns, ignore_conflicts=self._ignore_conflicts |
| 2127 | ) |
| 2128 | |
| 2129 | insert_query_all = insert_query |
| 2130 | if self.model._meta.generated_db_fields: |
| 2131 | columns_all = self._filter_columns(omit_fields, include_generated=True) |
| 2132 | if not columns_all: |
| 2133 | return default_sql, default_sql |
| 2134 | insert_query_all = self._executor._prepare_insert_statement( |
| 2135 | columns_all, |
| 2136 | has_generated=False, |
| 2137 | ignore_conflicts=self._ignore_conflicts, |
| 2138 | ) |
| 2139 | |
| 2140 | if self._update_fields: |
| 2141 | insert_query, insert_query_all = self._apply_on_conflict( |
| 2142 | insert_query, insert_query_all, self._update_fields, omit_fields |
| 2143 | ) |
| 2144 | |
| 2145 | return insert_query.get_sql(), insert_query_all.get_sql() |
| 2146 | |
| 2147 | async def _execute_many( |
| 2148 | self, |
no test coverage detected