@@ -107,14 +107,7 @@ def run
107
107
108
108
109
109
if @isWhere
110
- @where_conditions . each do |current_condition | #all where condtions will run for the current table row before the process_row runs
111
- current_condition . each do |key , value |
112
- if current_row [ key ] != value
113
- @all_conditions_met = false
114
- break
115
- end
116
- end
117
- end
110
+ @all_conditions_met = check_all_conditions_met ( current_row , @where_conditions )
118
111
process_row ( current_row , result_hash , @filtered_hash_array , @columns ) if @all_conditions_met
119
112
@final = @filtered_hash_array
120
113
end #isWhere
@@ -141,17 +134,7 @@ def run
141
134
updated_array = [ ]
142
135
header = CSV . read ( @table_name , headers :true ) . headers
143
136
CSV . foreach ( @table_name , headers :true ) do |current_csv_row |
144
- all_conditions_met = true
145
-
146
- @where_conditions . each do |current_condition |
147
- current_condition . each do |key , value |
148
- if current_csv_row [ key ] !=value
149
- all_conditions_met = false
150
- break
151
- end
152
- end
153
- end #where
154
-
137
+ all_conditions_met = check_all_conditions_met ( current_csv_row , @where_conditions )
155
138
if all_conditions_met
156
139
#then update the row before pushing to the csv
157
140
@dataToInsert . each do |current_condition |#[{"name"=>"Alaa Renamed", "college"=>"Renamed University"}]
@@ -242,7 +225,20 @@ def process_row(row,result_hash, selected_hash_array,columns)
242
225
selected_hash_array << result_hash if result_hash != {}
243
226
244
227
end
228
+ def check_all_conditions_met(current_row, where_conditions)
229
+ all_conditions_met = true
230
+
231
+ where_conditions.each do |current_condition|
232
+ current_condition.each do |key, value|
233
+ if current_row[key] != value
234
+ all_conditions_met = false
235
+ break
236
+ end
237
+ end
238
+ end
245
239
240
+ all_conditions_met
241
+ end
246
242
247
243
def merge_sort(array, &block)
248
244
return array if array.length <= 1
@@ -275,7 +271,11 @@ def merge(left, right, &block)
275
271
end
276
272
277
273
request = MySqliteRequest.new
278
- request = request.update('nba_player_data.csv')
279
- request = request.set('name' => 'Jimmy agabaje')
280
- request = request.where('name', 'Jim Zoet Renamed2')
281
- request.run
274
+ request=request.from('nba_players.csv')
275
+ request=request.select('player','height')
276
+ request=request.where('height','196')
277
+ request=request.run()
278
+ # request = request.update('nba_player_data.csv')
279
+ # request = request.set('name' => 'Jimmy agabaje2')
280
+ # request = request.where('name', 'Jimmy agabaje')
281
+ # request.run
0 commit comments