[关闭]
@liyuj 2018-01-27T15:57:24.000000Z 字数 4842 阅读 2397

Apache-Ignite-2.3.0-中文开发手册

8.PHP开发向导

8.1.PHP PDO

8.1.1.摘要

PHP提供了一个轻量级、一致的接口来访问数据库,叫做PHP数据对象-PDO,这个扩展依赖于若干特定数据库的PDO驱动,其中之一是PDO_ODBC,它可以接入任何实现了自己的ODBC驱动的数据库。
通过使用Ignite的ODBC驱动,从PHP应用中就可以接入Ignite集群,然后访问和修改数据,本文就会介绍如何达到该目的。

8.1.2.配置ODBC驱动

Ignite遵守ODBC协议,并且实现了自己的ODBC驱动,这个驱动会用于PHP的PDO框架接入Ignite集群。
查看本系列文档的ODBC部分,可以知道如何在目标系统上安装和配置这个驱动,安装完毕后,就可以进入下一个章节。

只能使用Ignite的1.8.0及以后的版本中的ODBC驱动,之前的版本不支持PHP的PDO框架。

8.1.3.安装和配置PHP PDO

要安装PHP,PDO以及PDO_ODBC驱动,可以看PHP的相关资源。

8.1.4.启动Ignite集群

PHP PDO准备就绪之后,就可以通过一个常规的配置启动Ignite集群,然后在PHP应用中接入集群并且查询和修改集群的数据。
首先,集群端已经起用了ODBC处理器,如何做呢,在每个集群节点的IgniteConfiguration中加入odbcConfiguration就可以了。
下一步,列出IgniteConfiguration中与特定数据模型有关的所有缓存的配置,因为之后要在PHP PDO端执行SQL查询,所有每个缓存的配置都需要包含一个QueryEntity的定义,可以查看有关SQL查询的文档,来了解有关QueryEntity和SQL查询的更多信息。
可以使用下面的配置模板启动一个Ignite集群:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:util="http://www.springframework.org/schema/util"
  5. xsi:schemaLocation="
  6. http://www.springframework.org/schema/beans
  7. http://www.springframework.org/schema/beans/spring-beans.xsd
  8. http://www.springframework.org/schema/util
  9. http://www.springframework.org/schema/util/spring-util.xsd">
  10. <bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
  11. <!-- Enabling ODBC. -->
  12. <property name="odbcConfiguration">
  13. <bean class="org.apache.ignite.configuration.OdbcConfiguration"></bean>
  14. </property>
  15. <!-- Configuring cache. -->
  16. <property name="cacheConfiguration">
  17. <list>
  18. <bean class="org.apache.ignite.configuration.CacheConfiguration">
  19. <property name="name" value="Person"/>
  20. <property name="cacheMode" value="PARTITIONED"/>
  21. <property name="atomicityMode" value="TRANSACTIONAL"/>
  22. <property name="writeSynchronizationMode" value="FULL_SYNC"/>
  23. <property name="queryEntities">
  24. <list>
  25. <bean class="org.apache.ignite.cache.QueryEntity">
  26. <property name="keyType" value="java.lang.Long"/>
  27. <property name="valueType" value="Person"/>
  28. <property name="fields">
  29. <map>
  30. <entry key="firstName" value="java.lang.String"/>
  31. <entry key="lastName" value="java.lang.String"/>
  32. <entry key="resume" value="java.lang.String"/>
  33. <entry key="salary" value="java.lang.Integer"/>
  34. </map>
  35. </property>
  36. <property name="indexes">
  37. <list>
  38. <bean class="org.apache.ignite.cache.QueryIndex">
  39. <constructor-arg value="salary"/>
  40. </bean>
  41. </list>
  42. </property>
  43. </bean>
  44. </list>
  45. </property>
  46. </bean>
  47. </list>
  48. </property>
  49. </bean>
  50. </beans>

8.1.5.从PHP端接入Ignite集群

要从PHP PDO端接入Ignite,需要正确地配置DSN,在下面的示例中,假定DSN名为LocalApacheIgniteDSN

注意,PHP PDO端必须配置使用DSN。

最后,都配置好之后,就可以在Ignite和PHP PDO应用之间相互连接了,可以像下面这样执行一些查询:
Insert

  1. <?php
  2. try {
  3. // Connecting to Ignite using pre-configured DSN.
  4. $dbh = new PDO('odbc:LocalApacheIgniteDSN');
  5. // Changing PDO error mode.
  6. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  7. // Preparing query.
  8. $dbs = $dbh->prepare('INSERT INTO Person (_key, firstName, lastName, resume, salary)
  9. VALUES (?, ?, ?, ?, ?)');
  10. // Declaring parameters.
  11. $key = 777;
  12. $firstName = "James";
  13. $lastName = "Bond";
  14. $resume = "Secret Service agent";
  15. $salary = 65000;
  16. // Binding parameters.
  17. $dbs->bindParam(1, $key);
  18. $dbs->bindParam(2, $firstName);
  19. $dbs->bindParam(3, $lastName);
  20. $dbs->bindParam(4, $resume);
  21. $dbs->bindParam(5, $salary);
  22. // Executing the query.
  23. $dbs->execute();
  24. } catch (PDOException $e) {
  25. print "Error!: " . $e->getMessage() . "\n";
  26. die();
  27. }
  28. ?>

Update:

  1. <?php
  2. try {
  3. // Connecting to Ignite using pre-configured DSN.
  4. $dbh = new PDO('odbc:LocalApacheIgniteDSN');
  5. // Changing PDO error mode.
  6. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  7. // Executing the query. The salary field is an indexed field.
  8. $dbh->query('UPDATE Person SET salary = 42000 WHERE salary > 50000');
  9. } catch (PDOException $e) {
  10. print "Error!: " . $e->getMessage() . "\n";
  11. die();
  12. }
  13. ?>

Select:

  1. <?php
  2. try {
  3. // Connecting to Ignite using pre-configured DSN.
  4. $dbh = new PDO('odbc:LocalApacheIgniteDSN');
  5. // Changing PDO error mode.
  6. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  7. // Executing the query and getting a result set. The salary field is an indexed field.
  8. $res = $dbh->query('SELECT firstName, lastName, resume, salary from Person
  9. WHERE salary > 12000');
  10. if ($res == FALSE)
  11. print_r("Exception");
  12. // Printing results.
  13. foreach($res as $row) {
  14. print_r($row);
  15. }
  16. } catch (PDOException $e) {
  17. print "Error!: " . $e->getMessage() . "\n";
  18. die();
  19. }
  20. ?>

Delete:

  1. <?php
  2. try {
  3. // Connecting to Ignite using pre-configured DSN.
  4. $dbh = new PDO('odbc:LocalApacheIgniteDSN');
  5. // Changing PDO error mode.
  6. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  7. // Performing query. Both firstName and lastName are non indexed fields.
  8. $dbh->query('DELETE FROM Person WHERE firstName = \'James\' and lastName = \'Bond\'');
  9. } catch (PDOException $e) {
  10. print "Error!: " . $e->getMessage() . "\n";
  11. die();
  12. }
  13. ?>
添加新批注
在作者公开此批注前,只有你和作者可见。
回复批注