@@ -74,7 +74,7 @@ export default {
7474 callback ( null , { rows : rows , total : 0 } ) ;
7575 }
7676 let rows = [ ] ;
77- let csvStream = csv ( options )
77+ let csvStream = csv . parse ( options )
7878 . on ( 'data' , function ( data ) {
7979 counter ++ ;
8080 //to limi the number of rows returned
@@ -206,7 +206,7 @@ export default {
206206 callback ( null , { output : '' } ) ;
207207 }
208208 let graphArr = [ ] ;
209- let csvStream = csv ( options )
209+ let csvStream = csv . parse ( options )
210210 . on ( 'data' , function ( data ) {
211211 counter ++ ;
212212 if ( counter === 1 ) {
@@ -230,7 +230,7 @@ export default {
230230 if ( ! prop . trim ( ) ) {
231231 continue ;
232232 }
233- if ( contextOptions [ 'idColumn' ] && prop . toLowerCase ( ) === contextOptions [ 'idColumn' ] . toLowerCase ( ) ) {
233+ if ( contextOptions [ 'idColumn' ] && camelCase ( prop ) . toLowerCase ( ) === contextOptions [ 'idColumn' ] . toLowerCase ( ) ) {
234234 tmpObj [ '@id' ] = validUrl . isUri ( data [ prop ] . toString ( ) ) ? data [ prop ] : 'r:' + encodeURIComponent ( camelCase ( data [ prop ] ) ) ;
235235 }
236236 if ( contextOptions [ 'skippedColumns' ] . indexOf ( camelCase ( prop ) ) === - 1 ) {
@@ -242,8 +242,8 @@ export default {
242242 }
243243 }
244244 //add a random ID if no ID column is specified
245- if ( ! contextOptions [ 'idColumn' ] ) {
246- tmpObj [ '@id' ] = 'r:' + counter + '_ ' + Math . round ( + new Date ( ) / 1000 ) ;
245+ if ( ! contextOptions [ 'idColumn' ] || contextOptions [ 'idColumn' ] === 'Not Applicable' ) {
246+ tmpObj [ '@id' ] = 'r:' + counter + '- ' + Math . floor ( Math . random ( ) * 10000000 ) ;
247247 }
248248 graphArr . push ( tmpObj ) ;
249249 //console.log(data);
0 commit comments