diff --git a/config/database.php b/config/database.php
index b7e9873..ece90e4 100644
--- a/config/database.php
+++ b/config/database.php
@@ -2,8 +2,8 @@
 
 return [
 
-   'default' => 'accounts',
-
+   'default' => 'mysql7',
+   'migrations' => 'migrations',
    'connections' => [
         'lelong' => [
             'driver'    => 'mysql',
@@ -451,4 +451,3 @@ return [
          ],
     ],
 ];
-
diff --git a/database/migrations/2023_11_14_121109_add_columns_to_komuditi_transaksi.php b/database/migrations/2023_11_14_121109_add_columns_to_komuditi_transaksi.php
new file mode 100644
index 0000000..971cbfc
--- /dev/null
+++ b/database/migrations/2023_11_14_121109_add_columns_to_komuditi_transaksi.php
@@ -0,0 +1,62 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+class AddColumnsToKomuditiTransaksi extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+
+
+    public function up()
+    {
+        Schema::connection($this->getOnlineArrahnConnection())->table('komuditi_transaksi', function (Blueprint $table){
+            $table->string('customer_id', 10, 2)->after('nosijil');
+            $table->float('harga', 10, 2)->after('nosijil');
+            $table->float('tan', 10, 2)->after('nosijil');
+            $table->string('no_sijil_pelanggan')->after('nosijil')->comment('format: no sijil bursa + no siri PKB');
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::connection($this->getOnlineArrahConnection())->table('komuditi_transaksi', function (Blueprint $table){
+            $table->dropColumn('no_sijil_pelanggan');
+            $table->dropColumn('tan');
+            $table->dropColumn('harga');
+            $table->dropColumn('customer_id');
+        });
+    }
+
+    private function getOnlineArrahnConnection()
+    {
+        $online_arrahn_connection_array = array_filter(config('database.connections'), function($connection) {
+
+            if($connection['database'] === 'online_arrahn'){
+                return true;
+            }
+
+
+            return false;
+
+        });
+
+
+        if(empty($online_arrahn_connection_array)){
+            throw new Exception("online_arrahn doesn't exist in config.database.connections array");
+        }
+
+        return array_keys($online_arrahn_connection_array)[0];
+
+    }
+}