Changeset View

Standalone View

Show First 20 Lines • Show All 147 Lines • ▼ Show 20 Lines	def copy_to(self, items, tblname, columns, default_values={},
write_thread = threading.Thread(target=writer)		write_thread = threading.Thread(target=writer)
write_thread.start()		write_thread.start()

try:		try:
with open(write_file, 'w') as f:		with open(write_file, 'w') as f:
for d in items:		for d in items:
if item_cb is not None:		if item_cb is not None:
item_cb(d)		item_cb(d)
line = [escape(d.get(k) or default_values.get(k))		line = [escape(d.get(k, default_values.get(k)))
for k in columns]		for k in columns]
f.write(','.join(line))		f.write(','.join(line))
f.write('\n')		f.write('\n')
finally:		finally:
# No problem bubbling up exceptions, but we still need to make sure		# No problem bubbling up exceptions, but we still need to make sure
# we finish copying, even though we're probably going to cancel the		# we finish copying, even though we're probably going to cancel the
# transaction.		# transaction.
write_thread.join()		write_thread.join()

def mktemp(self, tblname, cur=None):		def mktemp(self, tblname, cur=None):
self.cursor(cur).execute('SELECT swh_mktemp(%s)', (tblname,))		self.cursor(cur).execute('SELECT swh_mktemp(%s)', (tblname,))