今回は、PHP+mongoDBデータベースの操作手順と、PHP+mongoDBデータベースの注意事項について詳しく説明します。実際の事例を見てみましょう。
最近のプロジェクト開発で使用したデータベースは mongodb データベースです。私の会社では mongodb データベースを使用したばかりなので、これまで使用できるカプセル化された mongodb データベース操作クラスがなかったため、プロジェクト内で mongodb をカプセル化しました。データベース操作カテゴリは特別に共有されます。ここでは、不十分な部分を批判しないでください。
ご存知のとおり、mongodb は NoSQL データベースの代表的なものであり、近年特に人気が高まっています。MongoDB について簡単に説明します。 。
MongoDB は、リレーショナル データベースと非リレーショナル データベースの中間の製品であり、非リレーショナル データベースの中で最も機能が豊富で、最もリレーショナル データベースに似ています。サポートされるデータ構造は非常に緩やかで、json に似た bjson 形式であるため、より複雑な データ型 を格納できます。 Mongo の最大の特徴は、サポートするクエリ言語が非常に強力であることです。その構文は オブジェクト指向クエリ言語に似ており、リレーショナル データベースの単一テーブル クエリと同様のほとんどの機能を実装できます。データのインデックス作成。
高性能、簡単な導入、使いやすさ、そしてデータの保存に非常に便利であることが特徴です。主な機能特徴は次のとおりです:
コレクションストレージ向けで、オブジェクトタイプのデータを簡単に保存できます。 フリーモード。
動的クエリをサポートします。
内部オブジェクトを含む完全なインデックス作成をサポートします。
サポートのお問い合わせ。
レプリケーションと障害回復をサポートします。
大きなオブジェクト (ビデオなど) を含む、効率的なバイナリ データ ストレージを使用します。
フラグメンテーションを自動的に処理して、クラウド コンピューティング レベルのスケーラビリティをサポートします
RUBY、PYTHON、JAVA、C++、PHP およびその他の言語をサポートします。
ファイルの保存形式はBSON（JSONの拡張子）です
ネットワーク経由でアクセス可能です
いわゆる「コレクション指向」とは、データがグループ化され、コレクションと呼ばれるデータセットに保存されることを意味します（コレクション）。各コレクションにはデータベース内で一意の識別名があり、無制限の数のドキュメントを含めることができます。コレクションの概念はリレーショナル データベース (RDBMS) のテーブルに似ていますが、スキーマを定義する必要がないという点が異なります。
スキーマフリーとは、mongodb データベースに保存されているファイルについて、その構造定義を知る必要がないことを意味します。必要に応じて、異なる構造のファイルを同じデータベースに保存できます。
コレクションに保存されたドキュメントは、キーと値のペアとして保存されます。キーはドキュメントを一意に識別するために使用され、文字列タイプですが、値は任意の複雑なファイル タイプにすることができます。このストレージ形式を BSON (Binary Serialized dOcument Format) と呼びます。
MongoDB サーバーは Linux、Windows、または OS X プラットフォームで実行でき、32 ビットおよび 64 ビットのアプリケーションをサポートし、デフォルトのポートは 27017 です。 32 ビット モードで実行する場合、MongoDB
でサポートされる最大ファイル サイズは 2GB であるため、64 ビット プラットフォームで実行することをお勧めします。
MongoDB はデータをファイル (デフォルトのパス: /data/db) に保存し、効率を向上させるためにメモリマップされたファイルを管理に使用します。
<?php
/**
* PHP操作mongodb数据库操作类
*/
class Database {
protected $database = '';
protected $mo;
/**
* 构造方法
*/
public function construct() {
$server = DBSERVER;
$user = DBUSER;
$password = DBPASS;
$port = DBPORT;
$database = DBNAME;
$mongo = $this->getInstance($server, $user, $password, $port);
$this->database = $mongo->$database;
}
/**
* 数据库单例方法
* @param $server
* @param $user
* @param $password
* @param $port
* @return Mongo
*/
public function getInstance($server, $user, $password, $port) {
if (isset($this->mo)) {
return $this->mo;
} else {
if (!empty($server)) {
if (!empty($port)) {
if (!empty($user) && !empty($password)) {
$this->mo = new Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");
} else {
$this->mo = new Mongo("mongodb://{$server}:{$port}");
}
} else {
$this->mo = new Mongo("mongodb://{$server}");
}
} else {
$this->mo = new Mongo();
}
return $this->mo;
}
}
/**
* 查询表中所有数据
* @param $table
* @param array $where
* @param array $sort
* @param string $limit
* @param string $skip
* @return array|int
*/
public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
if (!empty($where)) {
$data = $this->database->$table->find($where);
} else {
$data = $this->database->$table->find();
}
if (!empty($sort)) {
$data = $data->sort($sort);
}
if (!empty($limit)) {
$data = $data->limit($limit);
}
if (!empty($skip)) {
$data = $data->skip($skip);
}
$newData = array();
while ($data->hasNext()) {
$newData[] = $data->getNext();
}
if (count($newData) == 0) {
return 0;
}
return $newData;
}
/**
* 查询指定一条数据
* @param $table
* @param array $where
* @return int
*/
public function getOne($table, $where = array()) {
if (!empty($where)) {
$data = $this->database->$table->findOne($where);
} else {
$data = $this->database->$table->findOne();
}
return $data;
}
/**
* 统计个数
* @param $table
* @param array $where
* @return mixed
*/
public function getCount($table, $where = array()) {
if (!empty($where)) {
$data = $this->database->$table->find($where)->count();
} else {
$data = $this->database->$table->find()->count();
}
return $data;
}
/**
* 直接执行mongo命令
* @param $sql
* @return array
*/
public function toExcute($sql) {
$result = $this->database->execute($sql);
return $result;
}
/**
* 分组统计个数
* @param $table
* @param $where
* @param $field
*/
public function groupCount($table, $where, $field) {
$cond = array(
array(
'$match' => $where,
),
array(
'$group' => array(
'_id' => '$' . $field,
'count' => array('$sum' => 1),
),
),
array(
'$sort' => array("count" => -1),
),
);
$this->database->$table->aggregate($cond);
}
/**
* 删除数据
* @param $table
* @param $where
* @return array|bool
*/
public function toDelete($table, $where) {
$re = $this->database->$table->remove($where);
return $re;
}
/**
* 插入数据
* @param $table
* @param $data
* @return array|bool
*/
public function toInsert($table, $data) {
$re = $this->database->$table->insert($data);
return $re;
}
/**
* 更新数据
* @param $table
* @param $where
* @param $data
* @return bool
*/
public function toUpdate($table, $where, $data) {
$re = $this->database->$table->update($where, array('$set' => $data));
return $re;
}
/**
* 获取唯一数据
* @param $table
* @param $key
* @return array
*/
public function distinctData($table, $key, $query = array()) {
if (!empty($query)) {
$where = array('distinct' => $table, 'key' => $key, 'query' => $query);
} else {
$where = array('distinct' => $table, 'key' => $key);
}
$data = $this->database->command($where);
return $data['values'];
}
}
?>ログイン後にコピー
この記事の事例を読んだ後は、この方法を習得したと思います。さらに興味深い情報については、php 中国語 Web サイトの他の関連記事に注目してください。
推奨読書:
php WeChatパブリックアカウントが現金赤い封筒機能をランダムに配布
PHP負荷分散下でのセッション共有ケースの詳細な説明(コード付き)
以上がPHP+mongoDBデータベース操作手順の詳細説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
