数据操作

论坛: 

Drupal如何连接到多个数据库?

允许Drupal连接多个数据库,需要转换$db_url为数组。

默认连接单个数据库的URL格式(字符串):

$db_url = ‘mysql://username:password@localhost/databasename’; 
$db_url = ‘mysqli://username:password@localhost/databasename’; 
$db_url = ‘pgsql://username:password@localhost/databasename’;

支持多个数据库的URL格式(数组):

$db_url['default'] = ‘mysql://drupal:drupal@localhost/drupal’; 
$db_url['mydb'] = ‘mysql://user:pwd@localhost/anotherdb’; 
$db_url['db3'] = ‘mysql://user:pwd@localhost/yetanotherdb’;

当查询一个不同的数据库时,简单地将数据库通过$db_url的引用键设置为当前活动的数据库,即可使用。

<?php 
db_set_active(‘mydb’); 
db_query(‘SELECT * FROM table_in_anotherdb’); 
// 当数据获取完成后,切换回默认的数据库连接。 
db_set_active(‘default’); 
?>

这是Drupal的数据库操作的基本操作。

Drupal连接到多个数据库后,但是发现程序报错,这是怎么了?

链接到多个数据库时出现报错,主要可能以下原因:

  • 连接到其他数据库时,SQL出错了,这个是人为的代码错误;
  • 连接数据库时交叉了,所以在其他数据库里找不到数据表,即使SQL正确,也要报错;

解决方法:

针对第一种情况,请根据SQL报错,来修改SQL语句,就解决了。

第二种情况,请检查数据库连接是否交叉了,意思就是本来想调用另外数据库的数据表,但是数据库连接已经换到其他地方了。关于数据库连接交叉,请仔细检查db_set_active这个函数之后的SQL语句,是否在active数据库里。

Drupal获取、添加、修改、删除多个数据库时,没有正常工作?

1、在Drupal中SQL语句可以不带数据表的前缀,只需要用大括号{}包含table就可以在数据库操作时加上数据表的前缀。

例如:db_query(‘SELECT * FROM {table_in_anotherdb}’);

但是一个数据库用户,如果拥有多个数据库的权限时,可以不用在$db_url设置连接到数据库,直接在当前数据库连接上操作就行了。

设置$db_prefix来实现跨数据库操作:

$db_prefix = array( 
    ‘default’ => ”, 
    ‘authmap’ => ‘z_’, 
    ‘profile_fields’ => ‘usertable.z_’, 
    ‘profile_values’ => ‘usertable.z_’, 
    ‘users_roles’ => ‘usertable.z_’, 
    ‘users_fields’ => ‘usertable.’, 
    ‘role’ => ‘usertable.z_’, 
    ‘sessions’ => ‘usertable.z_’, 
    ‘users’ => ‘usertable.z_’, 
);

上面的代码作用时,当前Drupal的用户等信息全部使用usertable,这样多个Drupal就可以共用一个用户信息数据库usertable,其中z_代表数据表的前缀。

注意:

  • users表用于存在Drupal用户的基本信息,可以存储所有用户共用的UID及其基本字段;
  • sessions表用于存放Drupal用户Sessions,可以统计所有站点的在线用户量;
  • role表用于存放所有Drupal站的角色;
  • users_roles存放所有Drupal站的权限;

通过上面的$db_prefix可以全局设置使用那个表要用到那个数据库,以及那个表的前缀,这个只是方便在Drupal的SQL语句中使用标准的{table}。

2、如果不通过$db_prefix来设置,那么最直白的方法就是直接把数据库 表名在SQL语句中。

例如:

db_query("SELECT uid FROM test.z_table1 WHERE name = ‘%s’ and pass = ‘%s’", $name, md5($pass));

上面的SQL语句直接定位到test数据库,z_table数据表。

所以当你遇到Drupal获取、添加、修改、删除多个数据库时,数据没有正确的写入数据库或者读取到空的数据,请明确你所控制的数据库、数据表位置是否正确。

在Drupal某个函数调用或控制其他数据库

请看下面的function框架代码:

function test_fuc() { 
  global $db_url; //获取全局变量 
  $db_url['db_logs'] = ‘mysqli://username:password@localhost/databasename’; 
  db_set_active(‘db_logs’); 
  $codehere; // 此处放置操作db_logs数据库连接的SQL 
  db_set_active(‘default’); 
}

特别要主要,$db_url是全局变量,需要在局部函数中用global引用:

global $db_url; //获取全局变量

设置完数据库后,记得使用db_set_active(‘default’);,设置数据库连接恢复到默认。

&lt;?php
$db_url = 'mysqli://user:password@localhost/drupal_site1';
$db_prefix = '';
?&gt;
To:

&lt;?php
$db_url = 'mysqli://user:password@localhost/drupal_site1';
$db_prefix = array(
'default' =&gt; '',
'authmap' =&gt; 'drupal_shared_tables.',
'profile_fields' =&gt; 'drupal_shared_tables.',
'profile_values' =&gt; 'drupal_shared_tables.',
'role' =&gt; 'drupal_shared_tables.',
'sessions' =&gt; 'drupal_shared_tables.',
'users' =&gt; 'drupal_shared_tables.',
);
?&gt;

dashan 答复于

drupal 7的多站点设置:

假使有两个站点,site1.dsjz.cn,site2,dsjz.cn

首先复制sites/default -> sites/site1.dsjz.cn      sites/default -> sites/site2.dsjz.cn
在sites/site1.dsjz.cn/settings.php 下面修改代码:

1
2
3
4
5
6
7
8
9
10
11
12
$databases['default']['default'] = array (
   'database' => 'db_site1',
   'username' => 'db_multi_user',
   'password' => 'db_multi_password',
   'host' => 'localhost',
   'port' => '',
   'driver' => 'mysql',
   'prefix' => '',
  );
// Read more about this variables in settings.php
$base_url = 'http://site1.dsjz.cn';
$cookie_domain = '.dsjz.cn'; // 这段能让网站单点登录,前提是多站点都是同一个域下的二级域

 

 

在sites/site1.dsjz.cn/settings.php 下面修改代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
$databases['default']['default'] = array (
   'database' => 'db_site2',
   'username' => 'db_multi_user',
   'password' => 'db_multi_password',
   'host' => 'localhost',
   'port' => '',
   'driver' => 'mysql',
   'prefix' => array(
    'default'   => 'db_site2.',
    'users'     => 'db_site1.',
    'sessions'  => 'db_site1.',
    'role'      => 'db_site1.',
    'authmap'   => 'db_site1.',
    'users_roles'   => 'db_site1.',
   ),
  );
// Read more about this variables in settings.php
$base_url = 'http://site.dsjz.cn';
$cookie_domain = '.dsjz.cn';

 

确保两个站点的文件夹sites/site1.dsjz.cn,sites/site2.dsjz.cn权限是666

确保sites/site1.dsjz.cn/files,sites/site2.dsjz.cn/files权限是777

 

site1.dsjz.cn , site2.dsjz.cn 指向服务器ip, 成功后,浏览器分别打开site1.dsjz.cn 安装, site2.dsjz.cn 安装

dashan 答复于

数据库抽象层给我们带来了多项好处,比如函数名称更好记了,查询中内置了安全特性,等等。有时候,我们需要连接到第3方或者遗留的数据库上,如果Drupal的数据库API能满足这一需要并同时提供安全特性的话,那该多美啊。不错,我们可以实现这一点!例如,在你的模块中,你可以连接到一个非Drupal的数据库,并从中取出数据。

在settings.php文件中,$db_url既可以是一个字符串(通常是这样的),也可以是包含多个数据库连接的字符串数组。下面是默认的语法,声明了一个单独的连接:

$db_url = 'mysql://username:password@localhost/databasename';

当使用一个数组时,它的键就是在激活数据库连接时所引用的简洁名称,而它的值就是连接的字符串本身。下面是一个例子,在这里我们声明了两个连接字符串, default(默认的)和legacy(遗留的):

$db_url['default'] = 'mysql://user:password@localhost/drupal6';
$db_url['legacy'] = 'mysql://user:password@localhost/legacydatabase';

注意 Drupal本身使用的数据库一定要以default为键。

    当你需要连接到Drupal中其它的数据库上时,你首先使用它的键名激活该连接,当你使用完连接时,将它切换回到默认的连接上。

// Get some information from a non-Drupal database.
db_set_active('legacy');
$result = db_query("SELECT * FROM ldap_user WHERE uid = %d", $user->uid);

// Switch back to the default connection when finished.
db_set_active('default');

注意 切记一定要切换回到默认的连接上,这样Drupal可以干净的完成整个请求生命周期并重新回到自己的表中。

    由于数据库抽象层设计的是为每个数据库使用相同的函数名,所以不能够同时使用多个数据库后台(比如,同时使用MySQL 和 PostgreSQL)。然而,在同一个站点还是可以同时使用MySQL 和 PostgreSQL连接的,如何实现的更多详细,请参看http://drupal.org/node/19522。

dashan 答复于

drupal多个数据库的切换。

1、定义数据库名称,用户名,前缀,编码等。
$databases = array(
   'default' =>
   array(
     'default' =>
     array(
       'driver' => 'mysql',
       'database' => 'databasename',
       'username' => 'username',
       'password' => 'password',
       'host' => 'localhost',
       'port' => 3306,
       'prefix' => 'myprefix_',
       'collation' => 'utf8_general_ci',
     ),
   ),
'legacy' =>
   array(
     'default' =>
     array(
       'driver' => 'mysql',
       'database' => 'legacydatabasename',
       'username' => 'legacyusername',
       'password' => 'legacypassword',
       'host' => 'legacy',
       'port' => 6060,
       'prefix' => 'legacyprefix_',
       'collation' => 'utf8_general_ci',
     ),
   ),

);

2、数据库的切换
//从其他数据库查询信息
db_set_active('legacy');
$result = db_query("select * from table where uid = :uid", array(':uid' => $user->uid));

//切换到默认数据库
db_set_active('default');

dashan 答复于

表联合查询

<?php
    $query = db_select('file_managed', 'fm');
    $query->join('field_data_field_image', 'fi', 'fm.fid = fi.field_image_fid');
    $query->groupBy('fm.fid'); 
    $query->fields('fm', array('filename', 'uri'));
    $query->fields('fi', array('field_image_width', 'field_image_height'));
    $query->condition('fi.bundle','image_for_slider','=');
    $result = $query->execute();
        while($record = $result->fetchAssoc()) {
            print_r($record);
        
    } 
?>
dashan 答复于