implemeted slect cli

Author: veiled-coder

mysqlite/my_sqlite_cli.rb

@@ -0,0 +1,70 @@
+
+require_relative 'my_sqlite_request'
+
+class MySQLite
+    def initialize
+    puts "MySQLite version 0.1 #{Time.now.strftime('%Y-%m-%d')}"
+    queryUserInput
+    end
+end    
+
+#SELECT * FROM students.db
+def queryUserInput
+loop do
+    print 'my_sqlite_cli>'
+    query=gets.chomp
+    result=''
+case query
+
+when 'exit'
+    puts 'exiting sqlte cli'
+    break
+when /^(\s*(SELECT|select)\s+([\w\s*,]+)\s+(FROM|from)\s+(\S+)\s*(?:(WHERE|where)\s+(.*?))?\s*)$/
+
+    column_name=$3
+    table_name="#{$5}.csv"
+    where_conditions=$7
+    result=runSelectQuery(table_name,column_name).run
+       
+    if where_conditions
+    result=runSelectWhereQuery(where_conditions,table_name,column_name).run      
+    end
+   
+    
+
+else
+    puts 'Invalid query format. Please enter a valid query...e.g..SELECT * FROM database.csv'  
+end#when
+puts result.inspect
+# return result
+end#loop
+end#defQuery
+
+# #HELPER FUNCTIONS
+
+    
+
+def runSelectQuery(table_name,column_name)
+    request = MySqliteRequest.new
+    request = request.from(table_name)
+    if column_name=="*"
+        request = request.select(column_name)
+    else
+        columNameArray=column_name.split(",")   #was "name,age" now ['name','age']
+        request = request.select(*columNameArray)
+    end
+    return request
+end
+
+def runSelectWhereQuery(conditions,table_name,column_name)
+    request=runSelectQuery(table_name,column_name)
+    splitted_conditions=conditions.split(",")#["name=Ivica Zubac", "year_start=1949"]   
+    splitted_conditions.each do |current_condition|
+        current_pair_array=current_condition.split("=")
+        request=request.where(*current_pair_array)
+    end
+    return request
+end
+
+MySQLite.new
+# select name,age from nba_player_data.csv

mysqlite/my_sqlite_request.rb

@@ -84,9 +84,9 @@ def delete
 def run
 
     if File.exist?(@table_name)
-      @hashedDataA=table_to_hashed(@table_name)
+      @hashedData=table_to_hashed(@table_name)
       else
-      @hashedDataA=create_csv_file(@table_name,@dataToInsert) if !File.exist?(table_name)
+      @hashedData=create_csv_file(@table_name,@dataToInsert) if !File.exist?(table_name)
     end
     @selected_hash_array=[] 
     @filtered_hash_array=[]
@@ -95,15 +95,15 @@ def run
 
 
     if @isJoin
-        joined_tables=join_tables(@hashedDataB,@hashedDataA,@filename_db_b,@column_on_db_b,@column_on_db_a)
-        @hashedDataA=joined_tables
+        joined_tables=join_tables(@hashedDataB,@hashedData,@filename_db_b,@column_on_db_b,@column_on_db_a)
+        @hashedData=joined_tables
     end
 
 
     #convert table data in CSV::Row to a HashedData
     case @request
       when 'select' # select the columns  from the each table row and corresponding data
-        @hashedDataA.each do |current_row|
+        @hashedData.each do |current_row|
             result_hash={}
             @all_conditions_met=true;
 
@@ -163,13 +163,13 @@ def run
 
         when 'delete'
           
-        table = CSV.table(@table_name) #delete_if is available in a tableMode
+        table = CSV.table(@table_name) #delete_if is available in a tableMode,headers in it are symbols
         header=CSV.read(@table_name,headers:true).headers
        
         @where_conditions.each do |current_condition|
           current_condition.each do |key, value|
            # Delete rows that match the condition
-            table.delete_if do |row|
+            table.delete_if do |row| 
               row[key.to_sym] == value
             end
           end
@@ -187,17 +187,13 @@ def run
       
       @final=csv_array
      
-       
-       
-        
-
-    end#case
+ end#case
         
   
     
 
 
-puts @final.inspect
+ @final
   end#of def run
 end#of class
 
@@ -305,11 +301,11 @@ def merge(left, right, &block)
 
   result
 end
-request = MySqliteRequest.new
-request = request.delete()
-request = request.from('nba_player_data.csv')
-request = request.where('name', 'Paul Zipser')
-request.run
+# request = MySqliteRequest.new
+# request = request.delete()-__+++
+# request = request.from('nba_player_data.csv')
+# request = request.where('name', 'Paul Zipser')
+# request.run
 # request = MySqliteRequest.new
 # request = request.update('nba_player_data.csv')
 # request = request.values('name' => 'Alaa Renamed')

mysqlite/my_sqlite_request.rb.csv

@@ -2,5 +2,5 @@ name,year_start,year_end,position,height,weight,birth_date,college
 Ante Zizic,2018,2018,F-C,6-11,250,"January 4, 1997",
 Jimmy agabaje2,1983,1983,C,7-1,240,"December 20, 1953",Kent State University
 Bill Zopf,1971,1971,G,6-1,170,"June 7, 1948",Duquesne University
-Ivica Zubac,2017,2018,C,7-1,265,"March 18, 1997",
+Ivica Zubac,2017,2018,C,7-1,265,"March 18, 1997",agege
 Matt Zunic,1949,1949,G-F,6-3,195,"December 19, 1919",George Washington University