lib/mini_sql/postgres/connection.rb in mini_sql-0.3 vs lib/mini_sql/postgres/connection.rb in mini_sql-1.0
- old
+ new
@@ -82,11 +82,11 @@
def query_array(sql, *params)
result = run(sql, params)
result.type_map = type_map
result.values
ensure
- result.clear if result
+ result.clear if result
end
def query(sql, *params)
result = run(sql, params)
result.type_map = type_map
@@ -95,13 +95,11 @@
result.clear if result
end
def query_each(sql, *params)
raise StandardError, "Please supply a block when calling query_each" if !block_given?
- if params && params.length > 0
- sql = param_encoder.encode(sql, *params)
- end
+ sql = param_encoder.encode(sql, *params)
raw_connection.send_query(sql)
raw_connection.set_single_row_mode
loop do
@@ -128,13 +126,11 @@
end
end
def query_each_hash(sql, *params)
raise StandardError, "Please supply a block when calling query_each_hash" if !block_given?
- if params && params.length > 0
- sql = param_encoder.encode(sql, *params)
- end
+ sql = param_encoder.encode(sql, *params)
raw_connection.send_query(sql)
raw_connection.set_single_row_mode
loop do
@@ -193,12 +189,10 @@
end
private
def run(sql, params)
- if params && params.length > 0
- sql = param_encoder.encode(sql, *params)
- end
+ sql = param_encoder.encode(sql, *params)
raw_connection.async_exec(sql)
end
end
end