May 27, 2020
0
Level 2
Converting RAW query into Eloquent query
i have a table called partner_transaction. On those table their is some column line - id, partner_id, amount, type(Debit, Credit) and balance. We wants to readjust all balance column by type for a specific partner. So we write a raw query -
update partner_transactions pt
inner join (
select
id, (select sum(case type when 'Credit' then amount when 'Debit' then -amount end)
from partner_transactions pt2
where pt2.partner_id = pt1.partner_id and pt2.id <= pt1.id
) balance
from partner_transactions pt1
WHERE pt1.partner_id = 65
) ptx
on ptx.id = pt.id AND pt.partner_id = 65
set pt.balance = ptx.balance
WHERE pt.partner_id = 65
Now we wants to convert in eloquent. So we write 2 function. 01. For calculating balance -
private function calculateBalanceQuery()
{
return DB::table('partner_transactions as pt1')
->where('pt1.partner_id', 65)
->selectRaw("id, (select sum(case type when 'Credit' then amount when 'Debit' then -amount end)
from partner_transactions pt2
where pt2.partner_id = pt1.partner_id and pt2.id <= pt1.id) balance"
);
}
- For Update -
public function updateQuery()
{
return PartnerTransaction::join(DB::raw('(' . $this->calculateBalanceQuery()->toSql() . ') ptx'), function ($join) {
$join->on('ptx.id', '=', 'partner_transactions.id')->on('partner_transactions.partner_id', '=', DB::raw("'65'"));
})
->where('partner_transactions.partner_id', 65)
->update(['partner_transactions.balance' => 'ptx.balance']);
}
But is not working, It gives us this error.
QueryException in Connection.php line 729:
SQLSTATE[HY093]: Invalid parameter number (SQL: update `partner_transactions` inner join (select id, (select sum(case type when 'Credit' then amount when 'Debit' then -amount end)
from partner_transactions pt2
where pt2.partner_id = pt1.partner_id and pt2.id <= pt1.id) balance from `partner_transactions` as `pt1` where `pt1`.`partner_id` = ptx.balance) ptx on `ptx`.`id` = `partner_transactions`.`id` and `partner_transactions`.`partner_id` = '65' set `partner_transactions`.`balance` = 65 where `partner_transactions`.`partner_id` = ?)
Please or to participate in this conversation.