lib/jetel/loaders/pg/pg.rb in jetel-0.0.7 vs lib/jetel/loaders/pg/pg.rb in jetel-0.0.8

@@ -38,13 +38,14 @@
 
       def load(modul, source, file, opts)
         super
 
         convert_opts = {
-          :l => 1_000,
+          :l => opts['analyze_num_rows'] && opts['analyze_num_rows'].to_i,
           :skip => 0,
-          :header => true
+          :header => true,
+          :delimiter => opts[:delimiter]
         }
 
         schema_list = Csv2Psql::Convert.generate_schema([file], convert_opts)
         _file_name, schema = schema_list.first
 
@@ -78,10 +79,11 @@
           :ctx => {
             :table => Helper.sanitize(source[:name]).downcase,
             :columns => schema[:columns],
             :source => source,
             :module => modul,
-            :file => File.absolute_path(modul.transformed_file(source, opts))
+            :file => File.absolute_path(modul.transformed_file(source, opts)),
+            :delimiter => opts[:delimiter]
           }
         }
 
         sql = Helper.erb_template(File.expand_path('../sql/schema.sql.erb', __FILE__), ctx)
         sql.gsub!("\n\n", "\n")