mirrors/pgloader
1
0
Fork 0
mirror of https://github.com/dimitri/pgloader.git synced 2026-05-04 10:31:02 +02:00
Code Issues Projects Releases Wiki Activity

FIX fixed reader: it now know about -C

Browse Source
This commit is contained in:
dim 2008-09-05 12:50:43 +00:00
parent 094313d7ff
commit 5f335eda28
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
pgloader/fixedreader.py
View File

@ -65,10 +65,34 @@ class FixedReader(DataReader):
start = self.start,
end = self.end)
# don't forget COUNT and FROM_COUNT option
nb_lines = 0
begin_linenb = None
##
# if -F was not used, we can state that begin = 0
#
# warning: FROM_ID is ignored
if FROM_COUNT == 0:
self.log.debug('beginning on first line')
begin_linenb = 1
for line in self.fd:
line = line.strip("\n")
llen = len(line)
columns = []
line = line.strip("\n")
llen = len(line)
columns = []
offsets = [self.fd.line_nb]
nb_lines += 1
##
# if -F is used, count lines to skip, and skip them
if FROM_COUNT > 0:
if nb_lines < FROM_COUNT:
continue
if nb_lines == FROM_COUNT:
begin_linenb = nb_lines
self.log.info('reached beginning on line %d', nb_lines)
for cname, cpos in self.columns:
start, length = self.positions[cname]