#NEWLINE# def export( self ) : #NEWLINE# #INDENT# tableNames = self . getTables ( ) #NEWLINE# fileNames = [ ( t + '_results.csv' ) for t in tableNames ] #NEWLINE# for t in fileNames : #NEWLINE# #INDENT# results_file = codecs . open ( ( t + '_results.csv' ) , encoding = 'utf-8' , mode = 'w+' ) #NEWLINE# rows = self . session . execute ( ( 'SELECT * FROM ' + t ) ) #NEWLINE# writer = csv . writer ( results_file ) #NEWLINE# writer . writerow ( self . getColumnsForTable ( t ) ) #NEWLINE# writer . writerows ( [ ( e for e in row ) for row in rows ] ) #NEWLINE# #UNINDENT# cypher_queries_gen = CypherQueriesGenerator ( self . keyspace_metadata , schema_file ) #NEWLINE# cypher_queries_gen . generate ( ) #NEWLINE# cypher_queries_gen . build_queries ( tableNames , fileNames )