javier/investbrain
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: support mariadb in sync:daily-change (#64)

Browse Source 
* fix: support mariadb in sync:daily-change

* use version() instead of system variables

---------

Co-authored-by: hackerESQ <corey@coreyvarma.com>
This commit is contained in:
Oscar Padilla
2025-02-25 20:09:03 -06:00
committed by GitHub
parent 0d06ca6a04
commit 6cff252813
1 changed files with 29 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Models/Holding.php
+29 -16
View File
@@ -7,6 +7,7 @@ namespace App\Models;
use Illuminate\Database\Eloquent\Concerns\HasUuids; use Illuminate\Database\Eloquent\Concerns\HasUuids;
use Illuminate\Database\Eloquent\Factories\HasFactory; use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB; use Illuminate\Support\Facades\DB;
class Holding extends Model class Holding extends Model
@@ -62,8 +63,8 @@ class Holding extends Model
return $this->hasMany(Dividend::class, 'symbol', 'symbol') return $this->hasMany(Dividend::class, 'symbol', 'symbol')
->select(['dividends.symbol', 'dividends.date', 'dividends.dividend_amount']) ->select(['dividends.symbol', 'dividends.date', 'dividends.dividend_amount'])
->selectRaw("SUM( ->selectRaw("SUM(
CASE WHEN transaction_type = 'BUY' CASE WHEN transaction_type = 'BUY'
AND transactions.symbol = dividends.symbol AND transactions.symbol = dividends.symbol
AND transactions.portfolio_id = '$this->portfolio_id' AND transactions.portfolio_id = '$this->portfolio_id'
AND date(dividends.date) >= date(transactions.date) AND date(dividends.date) >= date(transactions.date)
THEN transactions.quantity THEN transactions.quantity
@@ -71,22 +72,22 @@ class Holding extends Model
) AS purchased") ) AS purchased")
->selectRaw("SUM( ->selectRaw("SUM(
CASE WHEN transaction_type = 'SELL' CASE WHEN transaction_type = 'SELL'
AND transactions.symbol = dividends.symbol AND transactions.symbol = dividends.symbol
AND transactions.portfolio_id = '$this->portfolio_id' AND transactions.portfolio_id = '$this->portfolio_id'
AND date(dividends.date) >= date(transactions.date) AND date(dividends.date) >= date(transactions.date)
THEN transactions.quantity THEN transactions.quantity
ELSE 0 END ELSE 0 END
) AS sold") ) AS sold")
->selectRaw("SUM( ->selectRaw("SUM(
(CASE WHEN transaction_type = 'BUY' (CASE WHEN transaction_type = 'BUY'
AND transactions.symbol = dividends.symbol AND transactions.symbol = dividends.symbol
AND transactions.portfolio_id = '$this->portfolio_id' AND transactions.portfolio_id = '$this->portfolio_id'
AND date(transactions.date) <= date(dividends.date) AND date(transactions.date) <= date(dividends.date)
THEN transactions.quantity ELSE 0 END THEN transactions.quantity ELSE 0 END
- CASE WHEN transaction_type = 'SELL' - CASE WHEN transaction_type = 'SELL'
AND transactions.symbol = dividends.symbol AND transactions.symbol = dividends.symbol
AND transactions.portfolio_id = '$this->portfolio_id' AND transactions.portfolio_id = '$this->portfolio_id'
AND date(transactions.date) <= date(dividends.date) AND date(transactions.date) <= date(dividends.date)
THEN transactions.quantity ELSE 0 END) THEN transactions.quantity ELSE 0 END)
* dividends.dividend_amount * dividends.dividend_amount
) AS total_received") ) AS total_received")
@@ -253,7 +254,19 @@ class Holding extends Model
$date_interval = "date(date, '+1 day')"; $date_interval = "date(date, '+1 day')";
} else { } else {
DB::statement('SET cte_max_recursion_depth=1000000;'); // MySQL default
$max_recursion_var_name = 'cte_max_recursion_depth';
// Determine if running MySQL or MariaDB
$versionString = Arr::get(
DB::select('SELECT VERSION() as version;'),
'0.version', ''
);
if (stripos($versionString, 'MariaDB') !== false) {
$max_recursion_var_name = 'max_recursive_iterations'; // Must be MariaDB
}
DB::statement("SET $max_recursion_var_name=1000000;");
} }
return DB::table(DB::raw("( return DB::table(DB::raw("(
@@ -276,15 +289,15 @@ class Holding extends Model
COALESCE(SUM(CASE WHEN transactions.transaction_type = 'SELL' THEN transactions.quantity ELSE 0 END), 0), 3) AS `owned` COALESCE(SUM(CASE WHEN transactions.transaction_type = 'SELL' THEN transactions.quantity ELSE 0 END), 0), 3) AS `owned`
"), "),
DB::raw(" DB::raw("
COALESCE(CASE COALESCE(CASE
WHEN ( WHEN (
ROUND( ROUND(
COALESCE(SUM(CASE WHEN transactions.transaction_type = 'BUY' THEN transactions.quantity ELSE 0 END), 0) - COALESCE(SUM(CASE WHEN transactions.transaction_type = 'BUY' THEN transactions.quantity ELSE 0 END), 0) -
COALESCE(SUM(CASE WHEN transactions.transaction_type = 'SELL' THEN transactions.quantity ELSE 0 END), 0), 3) COALESCE(SUM(CASE WHEN transactions.transaction_type = 'SELL' THEN transactions.quantity ELSE 0 END), 0), 3)
) = 0 THEN 0 ) = 0 THEN 0
ELSE SUM(CASE ELSE SUM(CASE
WHEN transactions.transaction_type = 'BUY' THEN transactions.quantity * transactions.cost_basis WHEN transactions.transaction_type = 'BUY' THEN transactions.quantity * transactions.cost_basis
ELSE 0 ELSE 0
END) END)
END, 0) AS cost_basis END, 0) AS cost_basis
"), "),