use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;

class changeDatabase
{
    /**
     * getHandle incoming request.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return array
     */
    public function getHandle($request)
    {
        $params = $request->All();
        $sqlData = DB::table('sql_data')->where('sql_name', '=', $params['sql_name'])->first();//根据数据库名称查询数据库配置
        if (!$sqlData) {
            return Apis::first()->data()->attach('code', 400)->error('数据连接失败')->getJson();
        }
        DB::purge('mysql');//断开之前的数据库连接
        Config::set('database.connections.mysql.host',$sqlData->host);//数据库地址
        Config::set('database.connections.mysql.port',$sqlData->port);//端口
        Config::set('database.connections.mysql.database',$sqlData->database);//数据库名称
        Config::set('database.connections.mysql.username',$sqlData->username);//账号
        Config::set('database.connections.mysql.password',$sqlData->password);//密码
        //确保数据库重新连接了
        DB::reconnect('mysql');
        $data=  DB::select('select * from fa_admin where id >= 1', array(1));//对本次连接的数据库进行操作查询等等。。。
        return Apis::first()->data($data)->attach('code', 200)->success('数据连接成功')->getJson();
    }
}