(step, variables, cursor: Cursor, connection: Connection)
| 149 | |
| 150 | |
| 151 | def execute_step(step, variables, cursor: Cursor, connection: Connection): |
| 152 | action = step['action'] |
| 153 | query_template = step.get('query') |
| 154 | parameters = step.get('parameters', []) |
| 155 | expect = step.get('expect', {}) |
| 156 | |
| 157 | # Substitute variables in query |
| 158 | query_with_vars = substitute_variables(query_template, variables) |
| 159 | |
| 160 | # Replace parameter placeholders in query |
| 161 | query = adjust_placeholder_syntax(query_with_vars) |
| 162 | |
| 163 | resolved_parameters = resolve_parameters(parameters, variables) |
| 164 | |
| 165 | # Wrap varchar arrays for proper type encoding |
| 166 | resolved_parameters = wrap_varchar_arrays(resolved_parameters, parameters) |
| 167 | result = execute_query(cursor, query, resolved_parameters) |
| 168 | connection.commit() |
| 169 | |
| 170 | # Assert result |
| 171 | if expect: |
| 172 | assert_result(expect, result) |
| 173 | |
| 174 | |
| 175 | def run_test(test, global_variables, connection, binary): |
no test coverage detected
searching dependent graphs…