More Project DECOUPLE updates

Author: quinnj

REQUIRE

@@ -5,5 +5,6 @@ DataStreams
 DataFrames
 NullableArrays
 WeakRefStrings
+LegacyStrings
 @osx Homebrew
 @windows WinRPM

src/SQLite.jl

@@ -1,7 +1,7 @@
 VERSION >= v"0.4.0-dev+6521" && __precompile__(true)
 module SQLite
 
-using DataStreams, DataFrames, WeakRefStrings
+using DataStreams, DataFrames, WeakRefStrings, LegacyStrings
 
 export Data, DataFrame
 

src/Sink.jl

@@ -61,18 +61,19 @@ end
 # stream the data in `dt` into the SQLite table represented by `sink`
 function Data.stream!(source, ::Type{Data.Field}, sink::SQLite.Sink)
     rows, cols = size(source)
+    Data.isdone(source, 1, 1) && return sink
     types = Data.types(source)
     handle = sink.stmt.handle
     transaction(sink.db) do
-        row = 0
-        while !Data.isdone(source, row, cols)
-            row += 1
+        row = 1
+        while !Data.isdone(source, row, cols+1)
             for col = 1:cols
                 @inbounds T = types[col]
                 @inbounds getfield!(source, T, sink.stmt, row, col)
             end
             SQLite.sqlite3_step(handle)
             SQLite.sqlite3_reset(handle)
+            row += 1
         end
         Data.setrows!(source, rows)
     end