php - Laravel 5.2 - Make different Read/Write Connections -

-



in laravel 5.2, wanted have different connections read/write, followed advice provided in laravel documents. but, default, creating default mysql named connection , not 2 different read/write connections, therefore picking read connection operations insert/update.

after debugging, found in databasemanager.php file connection named passed argument makeconnection() mysql , not mysql::read or mysql::write.

before

config/database.php

'mysql' => [             //we need have nested options both read/write              'read' => [                 'host' => env('db_read_host'),             ],             'write' => [                 'host' => env('db_write_host'),                               ],               'host' => env('db_read_host'),               'username'  => env('db_username'),               'password'  => env('db_password'),               'driver'    => 'mysql',               'database'  => env('db_database'),               'collation' => 'utf8_unicode_ci',               'port'      => env('db_port', '3306'),               'charset'   => 'utf8',               'prefix'    => '',               'strict'    => false,         ],

file - vendor/laravel/framework/src/illuminate/database/databasemanager.php

public function connection($name = null)     {         list($name, $type) = $this->parseconnectionname($name);          // if haven't created connection, we'll create based on config         // provided in application. once we've created connections         // set "fetch mode" pdo determines query return types.         if (! isset($this->connections[$name])) {             $connection = $this->makeconnection($name);              $this->setpdofortype($connection, $type);              $this->connections[$name] = $this->prepare($connection);         }          return $this->connections[$name];     }

so, have added small change in file, after adding this, it's creating 2 different connections mysql.read/mysql.write , switching them appropriately according given sql operations select,insert,update

needed feedback if viable solution ?

after changing file

config/database.php 

'mysql' => [     //we need have nested options both read/write      'read' => [         'host' => env('db_read_host'),         'username'  => env('db_read_username'),         'password'  => env('db_read_password'),         'driver'    => 'mysql',         'database'  => env('db_database'),         'collation' => 'utf8_unicode_ci',         'port'      => env('db_port', '3306'),         'charset'   => 'utf8',         'prefix'    => '',         'strict'    => false,     ],     'write' => [         'host' => env('db_write_host'),         'username'  => env('db_write_username'),         'password'  => env('db_write_password'),          'driver'    => 'mysql',         'database'  => env('db_database'),         'collation' => 'utf8_unicode_ci',         'port'      => env('db_port', '3306'),         'charset'   => 'utf8',         'prefix'    => '',         'strict'    => false,      ],       'host' => env('db_read_host'),       'username'  => env('db_read_username'),       'password'  => env('db_read_password'),       'driver'    => 'mysql',       'database'  => env('db_database'),       'collation' => 'utf8_unicode_ci',       'port'      => env('db_port', '3306'),       'charset'   => 'utf8',       'prefix'    => '',       'strict'    => false, ],

file - vendor/laravel/framework/src/illuminate/database/databasemanager.php 

public function connection($name = null) {     list($name, $type) = $this->parseconnectionname($name);     // check if $type read/write , store appropriate connections     if( $type != null ) {         $name .= '.' . $type;     }     //end      // if haven't created connection, we'll create based on config     // provided in application. once we've created connections     // set "fetch mode" pdo determines query return types.     if (! isset($this->connections[$name])) {         $connection = $this->makeconnection($name);          $this->setpdofortype($connection, $type);          $this->connections[$name] = $this->prepare($connection);     }      return $this->connections[$name]; }





wiki

Comments

Post a Comment

Popular posts from this blog

python - Read npy file directly from S3 StreamingBody -

-
i have many .npy (numpy) , .json files saved in s3, need download , load these files. for json files downloading files , loading dictionary using following code: obj = s3.object(bucket, key) response = obj.get() body = response['body'].read().decode('utf-8') data = json.loads(body) that way avoid writing .json file disk , reading it. now want same .npy files, equivalent? currently downloading file, saving temp file on disk , loading np.load avoid if possible. following https://stackoverflow.com/a/28196540/3509999 : obj = s3.object(bucket, key) io.bytesio(obj.get()["body"].read()) f: # rewind file f.seek(0) arr = np.load(f) wiki
Read more

python - Minimize function with Scipy minimize -

-
trying obtain d value (integer) std_diff objective function minimal, using scipy minimize. my code: def std_diff(d): return std(diff(df['bn'].values,d)); scipy.optimize import minimize b=(3,) res = minimize(std_diff,(1,), method='slsqp', bounds = b) **df['bn'].values** out[72]: array([ 2, 2, 2, 2, 3, 2, 7, 5, 7, 11, 8, 2, 11, 7, 15, 8, 7, 12, 21, 19, 32, 35, 40, 35, 21, 19, 25, 20, 40, 80, 99], dtype=int64) error is"indexerror: many indices array " in case not use bounds : res = minimize(std_diff,(1,), method='slsqp'), error: > in _minimize_slsqp(func, x0, args, jac, bounds, constraints, maxiter, > ftol, iprint, disp, eps, callback, **unknown_options) > 368 fx = float(np.asarray(func(x))) > 369 except: > --> 370 raise valueerror("objective function must return scalar") > 371 # compute constraints > 3
Read more

kotlin - Out-projected type in generic interface prohibits the use of metod with generic parameter -

-
i start using kotlin , defined interface this: interface aadapter<vh : recyclerview.viewholder> { fun oncreateaviewholder(parent: viewgroup): vh fun onbindaviewholder(v: vh, position: int) } and when try use on code: class klasa ( private val adapter: aadapter<*> ) { fun dosth(){ //... val vh = this.adapter.oncreateaviewholder(parent) //on below line error adapter.onbindaviewholder(v, position) //... } } i error out-projected type 'aadapter<*>' prohibits use of 'public abstract fun onbindaviewholder(v: t, position: int): unit i tied add "in" or "out" definition i'm confused. how allow it. replace aadapter<*> aadapter<recyclerview.viewholder> . class klasa ( private val adapter: aadapter<recyclerview.viewholder> ) { // ... because have declared aadapter has type parameter vh type subclass of recyclerview.
Read more