{"id":979,"date":"2025-06-12T04:06:14","date_gmt":"2025-06-11T20:06:14","guid":{"rendered":"https:\/\/www.zhaozhao123.cn\/php\/php-application-manual\/laravel\/979.html"},"modified":"2025-06-12T04:06:14","modified_gmt":"2025-06-11T20:06:14","slug":"%e4%bc%98%e9%9b%85-orm%ef%bc%9a%e5%a6%82%e4%bd%95%e4%bd%bf%e7%94%a8%e5%a4%9a%e6%95%b0%e6%8d%ae%e5%ba%93%e8%bf%9e%e6%8e%a5","status":"publish","type":"my1js","link":"https:\/\/www.zhaozhao123.cn\/php\/my1js\/979.html","title":{"rendered":"\u4f18\u96c5 ORM\uff1a\u5982\u4f55\u4f7f\u7528\u591a\u6570\u636e\u5e93\u8fde\u63a5"},"content":{"rendered":"
\r\n
\r\n
\r\n
\r\n
\r\n
\"Bug编译狮\"<\/figure>\r\n\r\n\r\n\r\n

Bug编译狮<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n

优雅 ORM 是一种用于简化数据库操作的框架，它提供了强大的功能和灵活性。在实际应用中，多数据库连接是常见的需求之一，特别是在需要同时访问多个数据库场景下。下面是如何使用优雅 ORM 进行多数据库连接的详细步骤。<\/p>\n

1. 安装优雅 ORM<\/h3>\n

首先，你需要安装优雅 ORM 的库。你可以通过 npm 或 yarn 来安装：<\/p>\n

npm install @egjs\/orm<\/code><\/pre>\n
或者<\/p>\n
yarn add @egjs\/orm<\/code><\/pre>\n
2. 配置数据库连接<\/h3>\n
在你的项目中创建一个配置文件来定义不同的数据库连接信息。例如，database.config.js<\/code>：<\/p>\n
export const databases = {\n  default: {\n    host: 'localhost',\n    port: 5432,\n    user: 'postgres',\n    password: 'password',\n    database: 'default_db'\n  },\n  secondDatabase: {\n    host: 'localhost',\n    port: 5432,\n    user: 'postgres',\n    password: 'password',\n    database: 'second_db'\n  }\n};<\/code><\/pre>\n
3. 创建实体类<\/h3>\n
定义你的实体类，这些类将映射到数据库表。例如，User.js<\/code>：<\/p>\n
import { Model } from '@egjs\/orm';\n\nclass User extends Model {\n  static get tableName() {\n    return 'users';\n  }\n\n  static get columns() {\n    return [\n      { name: 'id', type: 'integer', primaryKey: true, autoIncrement: true },\n      { name: 'name', type: 'string' },\n      { name: 'email', type: 'string', unique: true }\n    ];\n  }\n}\n\nexport default User;<\/code><\/pre>\n
4. 使用多数据库连接<\/h3>\n
在你的服务或控制器中，你可以根据需要选择不同的数据库进行操作。例如，使用默认数据库：<\/p>\n
import { Database } from '@egjs\/orm';\nimport User from '.\/User';\n\nasync function createUser(user) {\n  const db = new Database(databases.default);\n  const result = await db.save(User, user);\n  return result;\n}<\/code><\/pre>\n
或者使用第二个数据库：<\/p>\n
import { Database } from '@egjs\/orm';\nimport User from '.\/User';\n\nasync function createUserWithSecondDb(user) {\n  const db = new Database(databases.secondDatabase);\n  const result = await db.save(User, user);\n  return result;\n}<\/code><\/pre>\n
5. 示例代码<\/h3>\n
以下是一个完整的示例，展示了如何使用优雅 ORM 进行多数据库连接：<\/p>\n
\/\/ database.config.js\nexport const databases = {\n  default: {\n    host: 'localhost',\n    port: 5432,\n    user: 'postgres',\n    password: 'password',\n    database: 'default_db'\n  },\n  secondDatabase: {\n    host: 'localhost',\n    port: 5432,\n    user: 'postgres',\n    password: 'password',\n    database: 'second_db'\n  }\n};\n\n\/\/ User.js\nimport { Model } from '@egjs\/orm';\n\nclass User extends Model {\n  static get tableName() {\n    return 'users';\n  }\n\n  static get columns() {\n    return [\n      { name: 'id', type: 'integer', primaryKey: true, autoIncrement: true },\n      { name: 'name', type: 'string' },\n      { name: 'email', type: 'string', unique: true }\n    ];\n  }\n}\n\nexport default User;\n\n\/\/ UserService.js\nimport { Database } from '@egjs\/orm';\nimport User from '.\/User';\n\nasync function createUser(user) {\n  const db = new Database(databases.default);\n  const result = await db.save(User, user);\n  return result;\n}\n\nasync function createUserWithSecondDb(user) {\n  const db = new Database(databases.secondDatabase);\n  const result = await db.save(User, user);\n  return result;\n}\n\n\/\/ main.js\n(async () => {\n  try {\n    const newUser = { name: 'John Doe', email: 'john.doe@example.com' };\n    const createdUser = await createUser(newUser);\n    console.log('Created user with default database:', createdUser);\n\n    const newUserWithSecondDb = { name: 'Jane Smith', email: 'jane.smith@example.com' };\n    const createdUserWithSecondDb = await createUserWithSecondDb(newUserWithSecondDb);\n    console.log('Created user with second database:', createdUserWithSecondDb);\n  } catch (error) {\n    console.error(error);\n  }\n})();<\/code><\/pre>\n
通过以上步骤，你可以在优雅 ORM 中成功实现多数据库连接。这种方法不仅提高了代码的可维护性和扩展性，还使得数据库操作更加简洁和高效。<\/p>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>
\r\n
\r\n
\r\n
\r\n
\r\n
\"黑板Bug讲师\"<\/figure>\r\n\r\n\r\n\r\n
黑板Bug讲师<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n
介绍<\/h2>
在使用Laravel开发应用时，利用其内置的ORM（对象关系映射）Eloquent进行数据库交互是一种优雅的方法。然而，随着应用程序复杂度的增加，需要同时连接多个数据库的情况变得越来越常见，这可能是为了分离数据关注点、提升性能或与遗留系统协同工作。在这篇教程中，我们将学习如何使用Eloquent ORM轻松处理多数据库连接。<\/p>
理解 eloquent 配置<\/h2>
在深入多连接之前，理解Laravel中的Eloquent是如何配置的非常重要。数据库设置的默认配置文件通常位于config\/database.php<\/code>在这一文件中，您将会找到一个connections<\/code>我们应用可以使用的连接数组，每个键代表一个连接名称，值包括驱动程序、主机名、数据库名、用户名和密码等详细信息。<\/p>
'connections' => [\n  'mysql' => [\n    'driver' => 'mysql',\n    'host' => env('DB_HOST', '127.0.0.1'),\n    'database' => env('DB_DATABASE', 'forge'),\n    'username' => env('DB_USERNAME', 'forge'),\n    'password' => env('DB_PASSWORD', ''),\n    'charset' => 'utf8mb4',\n    'collation' => 'utf8mb4_unicode_ci',\n    'prefix' => '',\n    'strict' => true,\n    'engine' => null,\n  ],\n  \/\/ Additional connections...\n],<\/code><\/pre>
为了建立另一个数据库连接，你需要在现有的数组下添加一个包含您所需配置的新数组。mysql<\/code>连接已经建立。<\/p>
创建多个连接<\/h2>
Laravel使得管理多个连接变得轻而易举。以下是配置额外连接的步骤：config\/database.php<\/code>：<\/p>
'connections' => [\n  'mysql' => [\n    \/\/ Primary database connection details...\n  ],\n  'secondary' => [\n    'driver' => 'mysql',\n    'host' => env('SECONDARY_DB_HOST', '127.0.0.2'),\n    'database' => env('SECONDARY_DB_DATABASE', 'secondary'),\n    'username' => env('SECONDARY_DB_USERNAME', 'root'),\n    'password' => env('SECONDARY_DB_PASSWORD', ''),\n    'charset' => 'utf8',\n    'collation' => 'utf8_unicode_ci',\n    'prefix' => '',\n    'strict' => false,\n    'engine' => null,\n  ],\n  \/\/ Other connections...\n],<\/code><\/pre>
当我们定义了额外的连接后，我们可以明确地告诉Eloquent模型使用它们。<\/p>
在模型中指定连接点。<\/h2>
你可以为模型指定特定的连接，通过定义来实现。$connection<\/code>例如：<\/p>
namespace AppModels;\n\nuse IlluminateDatabaseEloquentModel;\n\nclass SecondaryModel extends Model\n{\n  protected $connection = 'secondary';\n\n  \/\/ Model's methods and attributes...\n}<\/code><\/pre>
通过这样做，任何Eloquent查询都会被自动缓存。SecondaryModel<\/code>会用的secondary<\/code>连接而不是默认的。<\/p>
动态连接切换<\/h2>
有时，您可能希望动态切换连接，这取决于用户的数据或请求参数。可以通过使用以下方法实现这一点。setConnection()<\/code>方法。例如：<\/p>
$user = new User;\n$user->setConnection('secondary');\n$data = $user->find(1);<\/code><\/pre>
您的模型将在进行此交易时暂时切换到“次级”连接。此切换不会影响全局模型行为，保持操作紧密且特定于上下文。<\/p>
原始查询和多个连接<\/h2>
原始数据库查询也可以在不同的连接上执行。您可以使用这个。DB<\/code>facade的connection()<\/code>方法：<\/p>
use IlluminateSupportFacadesDB;\n\n$results = DB::connection('secondary')->select('SELECT * FROM table_name');<\/code><\/pre>
这种做法会执行您次级数据库上的查询。在处理原始查询时，总是要对输入进行清理以防止SQL注入攻击。<\/p>
使用多个数据库与迁移管理<\/h2>
Laravel的迁移系统支持多个数据库。在运行迁移时，可以通过指定连接来使用它。--database<\/code>旗标。您还可以在迁移文件中直接定义一个连接，如下所示：<\/p>
public function up()\n{\n  Schema::connection('secondary')->create('some_table', function ($table) {\n    $table->bigIncrements('id');\n    \/\/ Other columns...\n  });\n}<\/code><\/pre>
同样，从特定的连接回滚迁移也很方便，你可以利用连接方法进行操作。Schema::connection('secondary')<\/code>在down方法中。<\/p>
处理多个数据库的提示。<\/h2>
在跨数据库事务处理时要非常小心，这可能会导致数据完整性的问题。<\/p>
在开发过程中定期备份数据，因为涉及到多个数据库。<\/p>
为每个连接保留单独目录的迁移文件，以保持清晰度。<\/p>
结论。<\/h2>
在Laravel中与多个数据库一起工作既可行又简单。无论是静态指定模型中的数据库连接，还是动态地在运行时更改它们，整个过程都对开发者友好且易于操作，这符合Laravel的口号“写表达式优雅的语法”。<\/p><\/body>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>
\r\n
\r\n
\r\n
\r\n
\r\n
\"长工码奴1523\"<\/figure>\r\n\r\n\r\n\r\n
长工码奴1523<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n
在Python中，我们可以使用psycopg2<\/code>库来处理PostgreSQL数据库，它提供了对PostgreSQL的封装，使得我们不需要关心底层的驱动和协议细节。同时，为了更好地管理多个数据库连接，可以使用asyncio<\/code>模块中的async with<\/code>语句。<\/p>\n
以下是如何在Python中使用psycopg2<\/code>库创建多个数据库连接，并使用这些连接执行SQL查询的例子：<\/p>\n
import asyncio\n\n# 创建数据库连接池\nasync def create_pool():\n    pool = await aiopg.create_pool(\n        user='postgres',\n        host='127.0.0.1',\n        database='mydb',\n        password='password',\n        port=5432,\n        loop=loop\n    )\n    return pool\n\n# 执行SQL查询并返回结果集\nasync def execute_query(pool, query):\n    cursor = await pool.cursor()\n    result = await cursor.execute(query)\n    await cursor.fetchone()\n    await cursor.close()\n\n# 使用多个数据库连接池\npool_a = await create_pool()\npool_b = await create_pool()\n\n# 连接数据库\nasync with pool_a.acquire() as connection:\n    async with connection.transaction():\n        # 执行SQL查询\n        await execute_query(connection, 'SELECT * FROM my_table')\n\n        # 关闭事务\n        await connection.commit()\n        await connection.close()\n\nasync with pool_b.acquire() as connection:\n    async with connection.transaction():\n        # 执行SQL查询\n        await execute_query(connection, 'SELECT * FROM my_table')\n\n        # 关闭事务\n        await connection.commit()\n        await connection.close()\n\n# 关闭所有连接池\nawait pool_a.release()\nawait pool_b.release()<\/code><\/pre>\n
在这个例子中，我们首先定义了两个数据库连接池函数：create_pool()<\/code> 和 execute_query()<\/code>。然后，我们在主事件循环中使用async with<\/code>语句创建和释放多个数据库连接。每次使用一个新的连接时，都会自动关闭该连接，从而避免了资源泄漏的问题。<\/p>\n
注意：这个例子假设你已经安装了aiopg<\/code>库，并且你的服务器上有一个名为mydb<\/code>的PostgreSQL数据库。你需要根据实际情况调整数据库信息（用户名、密码等）。<\/p>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>\n","protected":false},"excerpt":{"rendered":"
Bug编译狮 优雅 ORM 是一种用于简化数据库操作的&#26694..<\/p>\n","protected":false},"author":1,"featured_media":0,"menu_order":0,"template":"","meta":{"_acf_changed":false},"tags":[],"my1js2nav":[44],"tuisongtax":[],"class_list":["post-979","my1js","type-my1js","status-publish","hentry","my1js2nav-laravel"],"acf":{"qian_art_seotitle":"","qian_art_seotitle_source":{"label":"SEO\u6807\u9898","type":"text","formatted_value":""},"qian_art_seokws":"","qian_art_seokws_source":{"label":"SEO\u5173\u952e\u8bcd","type":"text","formatted_value":""},"qian_art_stzhong":"","qian_art_stzhong_source":{"label":"\u4e2d | \u77ed\u6807\u9898","type":"text","formatted_value":""}},"_links":{"self":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js\/979","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js"}],"about":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/types\/my1js"}],"author":[{"embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/users\/1"}],"wp:attachment":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/media?parent=979"}],"wp:term":[{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/tags?post=979"},{"taxonomy":"my1js2nav","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js2nav?post=979"},{"taxonomy":"tuisongtax","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/tuisongtax?post=979"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}