Basic support for SQLite(Sqlite3Cursor) => DataFrame

Author: King-Ozymandias

src/BaselineOfDataFrame/BaselineOfDataFrame.class.st

@@ -1,10 +1,11 @@
 Class {
-	#name : #BaselineOfDataFrame,
-	#superclass : #BaselineOf,
-	#category : #BaselineOfDataFrame
+	#name : 'BaselineOfDataFrame',
+	#superclass : 'BaselineOf',
+	#category : 'BaselineOfDataFrame',
+	#package : 'BaselineOfDataFrame'
 }
 
-{ #category : #baselines }
+{ #category : 'baselines' }
 BaselineOfDataFrame >> baseline: spec [
 	<baseline>
 	spec for: #common do: [
@@ -18,13 +19,20 @@ BaselineOfDataFrame >> baseline: spec [
 		spec
 			baseline: 'AINormalization'
 			with: [ spec repository: 'github://pharo-ai/normalization/src' ].
+		spec
+			baseline: 'SQLite3'
+			with: [ spec repository: 'github://pharo-rdbms/Pharo-SQLite3/src' ].
 
 		"Packages"
 		spec
 			package: 'DataFrame' with: [ spec requires: #('AINormalization') ];
 			package: 'DataFrame-Tests' with: [ spec requires: #('DataFrame') ];
 			package: 'DataFrame-IO' with: [ spec requires: #('DataFrame' 'NeoCSV' 'NeoJSON') ];
+			package: 'DataFrame-IO-Sqlite' with: [ spec requires: #('DataFrame' 'SQLite3') ];
 			package: 'DataFrame-IO-Tests' with: [ spec requires: #('DataFrame-IO') ] ].
+		
+		spec group: 'default' with: #('DataFrame-IO-Tests').
+		spec group: 'sqlite' with: #('DataFrame-IO-Sqlite' 'DataFrame-IO-Tests').
 
 		spec
 			for: #'pharo7.x'
@@ -37,5 +45,5 @@ BaselineOfDataFrame >> baseline: spec [
 			do: [
 				spec
 					package: 'DataFrame-Pharo6';
-					package: 'DataFrame-Pharo67' ]
+					package: 'DataFrame-Pharo67' ]	
 ]

src/BaselineOfDataFrame/package.st

@@ -1 +1 @@
-Package { #name : #BaselineOfDataFrame }
+Package { #name : 'BaselineOfDataFrame' }

src/DataFrame-IO-Sqlite/DataFrame.extension.st

@@ -0,0 +1,9 @@
+Extension { #name : 'DataFrame' }
+
+{ #category : '*DataFrame-IO-Sqlite' }
+DataFrame class >> readFromSqliteCursor: aSqliteCursor [
+
+	| reader |
+	reader := DataFrameSqliteReader new.
+	^ self readFrom: aSqliteCursor using: reader
+]

src/DataFrame-IO-Sqlite/DataFrameSqliteReader.class.st

@@ -0,0 +1,15 @@
+Class {
+	#name : 'DataFrameSqliteReader',
+	#superclass : 'DataFrameReader',
+	#category : 'DataFrame-IO-Sqlite',
+	#package : 'DataFrame-IO-Sqlite'
+}
+
+{ #category : 'reading' }
+DataFrameSqliteReader >> readFrom: aSqliteCursor [
+	"Read all rows from cursor, stuff them into a new dataframe with columns of same name"
+
+	| cols |
+	cols := aSqliteCursor columnNames. "need to grab columns before exhausting the cursor"
+	^ DataFrame withRows: aSqliteCursor rows columnNames: cols
+]

src/DataFrame-IO-Sqlite/package.st

@@ -0,0 +1 @@
+Package { #name : 'DataFrame-IO-Sqlite' }