equal
deleted
inserted
replaced
157 self.execute_children() |
157 self.execute_children() |
158 sql = self.get_sql() |
158 sql = self.get_sql() |
159 if self.outputtable: |
159 if self.outputtable: |
160 self.plan.create_temp_table(self.outputtable) |
160 self.plan.create_temp_table(self.outputtable) |
161 sql = 'INSERT INTO %s %s' % (self.outputtable, sql) |
161 sql = 'INSERT INTO %s %s' % (self.outputtable, sql) |
162 return self.plan.sqlexec(sql, self.plan.args) |
162 self.plan.syssource.doexec(self.plan.session, sql, self.plan.args) |
|
163 else: |
|
164 return self.plan.sqlexec(sql, self.plan.args) |
163 |
165 |
164 def get_sql(self): |
166 def get_sql(self): |
165 self.inputmap = inputmap = self.children[-1].outputmap |
167 self.inputmap = inputmap = self.children[-1].outputmap |
166 dbhelper=self.plan.syssource.dbhelper |
168 dbhelper=self.plan.syssource.dbhelper |
167 # get the select clause |
169 # get the select clause |