Skip to content

Commit aedf993

Browse files
committed
Cleanup affected row
1 parent e6a05b2 commit aedf993

File tree

1 file changed

+13
-9
lines changed

1 file changed

+13
-9
lines changed

lib/active_record/connection_adapters/sqlserver/database_statements.rb

Lines changed: 13 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -75,14 +75,16 @@ def cast_result(raw_result)
7575

7676
def affected_rows(raw_result)
7777

78-
if raw_result.count == 1 && raw_result.first.key?('AffectedRows')
79-
raw_result.first['AffectedRows']
80-
else
81-
raw_result.count
82-
end
78+
raw_result.first['AffectedRows']
8379

84-
rescue => e
85-
binding.pry
80+
# if raw_result.count == 1 && raw_result.first.key?('AffectedRows')
81+
# raw_result.first['AffectedRows']
82+
# else
83+
# raw_result.count
84+
# end
85+
86+
# rescue => e
87+
# binding.pry
8688
end
8789

8890

@@ -118,14 +120,16 @@ def internal_exec_sql_query(sql, conn)
118120
finish_statement_handle(handle)
119121
end
120122

121-
def exec_delete(sql, name, binds)
123+
def exec_delete(sql, name = nil, binds = [])
122124
sql = sql.dup << "; SELECT @@ROWCOUNT AS AffectedRows"
123125
super(sql, name, binds)
126+
# internal_execute(sql, name, binds).first['AffectedRows']
124127
end
125128

126-
def exec_update(sql, name, binds)
129+
def exec_update(sql, name = nil, binds = [])
127130
sql = sql.dup << "; SELECT @@ROWCOUNT AS AffectedRows"
128131
super(sql, name, binds)
132+
# internal_execute(sql, name, binds).first['AffectedRows']
129133
end
130134

131135
def begin_db_transaction

0 commit comments

Comments
 (0)