csv: bit faster, simpler.

db4
John Benediktsson 2012-07-27 13:22:32 -07:00
parent 01abb351b5
commit 1949e4c2d9
1 changed files with 43 additions and 38 deletions

View File

@ -1,8 +1,8 @@
! Copyright (C) 2007, 2008 Phil Dawes
! See http://factorcode.org/license.txt for BSD license.
USING: kernel sequences io namespaces make combinators
unicode.categories io.files combinators.short-circuit
io.streams.string fry memoize ;
USING: combinators fry io io.files io.streams.string kernel
make math memoize namespaces sequences sequences.private
unicode.categories ;
IN: csv
SYMBOL: delimiter
@ -16,56 +16,58 @@ CHAR: , delimiter set-global
MEMO: (field-end) ( delimiter -- delimiter' )
"\n" swap suffix ; inline
: field-end ( -- str sep )
delimiter> (field-end) read-until ; inline
DEFER: quoted-field
MEMO: (quoted-field) ( delimiter -- delimiter' )
"\"\n" swap suffix ; inline
: maybe-escaped-quote ( quoted? -- endchar )
read1 dup {
{ CHAR: " [ over [ , ] [ drop ] if quoted-field ] }
{ delimiter> [ ] }
DEFER: quoted-field
: maybe-escaped-quote ( delimeter quoted? -- delimiter endchar )
read1 pick over =
[ nip ] [
{
{ CHAR: " [ [ CHAR: " , ] when quoted-field ] }
{ CHAR: \n [ ] } ! Error: newline inside string?
[ [ , f maybe-escaped-quote ] when ]
} case nip ;
: quoted-field ( -- endchar )
"\"" read-until
drop % t maybe-escaped-quote ;
: ?trim ( string -- string' )
dup { [ first blank? ] [ last blank? ] } 1||
[ [ blank? ] trim ] when ;
: field ( -- sep string )
delimiter> (quoted-field) read-until
dup CHAR: " = [
over empty?
[ 2drop [ quoted-field ] "" make ]
[ drop field-end [ "\"" glue ] dip swap ?trim ]
if
] [
swap [ "" ] [ ?trim ] if-empty
[ [ , drop f maybe-escaped-quote ] when* ]
} case
] if ;
: (row) ( -- sep )
f delimiter> '[ dup _ = ]
[ drop field , ] do while ;
: quoted-field ( delimiter -- delimiter endchar )
"\"" read-until drop % t maybe-escaped-quote ;
: row ( -- eof? array[string] )
: ?trim ( string -- string' )
dup length [ drop "" ] [
over first-unsafe blank?
[ drop t ] [ 1 - over nth-unsafe blank? ] if
[ [ blank? ] trim ] when
] if-zero ; inline
: field ( delimiter -- delimiter sep string )
dup (quoted-field) read-until
dup CHAR: " = [
drop
[ [ quoted-field ] "" make ]
[
over (field-end) read-until
[ "\"" glue ] dip swap ?trim
]
if-empty
] [ swap ?trim ] if ;
: (row) ( delimiter -- delimiter sep )
f [ 2dup = ] [ drop field , ] do while ;
: row ( delimiter -- delimiter eof? array[string] )
[ (row) ] { } make ;
: (csv) ( -- )
delimiter>
[ dup [ empty? ] all? [ drop ] [ , ] if ]
[ row ] do while ;
[ row ] do while drop ;
PRIVATE>
: csv-row ( stream -- row )
[ row nip ] with-input-stream ;
[ delimiter> row 2nip ] with-input-stream ;
: csv ( stream -- rows )
[ [ (csv) ] { } make ] with-input-stream
@ -102,16 +104,19 @@ PRIVATE>
dup needs-escaping?
[ escape-quotes enclose-in-quotes ] when ; inline
: (write-row) ( row delimiter -- )
'[ _ write1 ]
[ escape-if-required write ] interleave nl ; inline
PRIVATE>
: write-row ( row -- )
delimiter> '[ _ write1 ]
[ escape-if-required write ] interleave nl ; inline
delimiter> (write-row) ; inline
<PRIVATE
: (write-csv) ( rows -- )
[ write-row ] each ;
delimiter> '[ _ (write-row) ] each ;
PRIVATE>