PHP 작업 MongoDB 클래스 샘플 코드
mongodb
php
암호
이 글에서는 주로 PHP에서 MongoDB 클래스를 동작시키는 방법을 소개합니다. 예제에서는 CI 이후에 구현된 MongoDB 클래스와 그 동작 기법을 분석합니다. 필요한 친구들이 참고할 수 있습니다.
이 글의 예제는 MongoDB를 동작시키는 방법을 설명합니다. PHP의 클래스. 참고할 수 있도록 모든 사람과 공유하세요. 세부 사항은 다음과 같습니다:
1.MyMongo.php 파일:
<?php
/**
* 仿写CI的MongoDB
* @author sparkHuang 2011-11-03
*
*/
class MyMongo {
private $mongo_config = "mongo_config.php";
private $connection;
private $db;
private $mongo_connect_string;
private $host;
private $port;
private $user;
private $pass;
private $dbname;
private $persist;
private $persist_key;
private $selects = array();
private $wheres = array();
private $sorts = array();
private $limit = 999999;
private $offset = 0;
public function construct() {
if ( ! class_exists('Mongo')) {
$this->log_error("The MongoDB PECL extentiosn has not been installed or enabled.");
exit;
}
$this->connection_string();
$this->connect();
}
/**
* 更改数据库
*
*/
public function switch_db($database = '') {
if (empty($database)) {
$this->log_error("To switch MongoDB databases, a new database name must be specified");
exit;
}
$this->dbname = $database;
try {
$this->db = $this->connection->{$this->dbname};
return true;
} catch(Exception $e) {
$this->log_error("Unable to switch Mongo Databases: {$e->getMessage()}");
exit;
}
}
/**
* 设置select字段
*
*/
public function select($includs = array(), $excludes = array()) {
if ( ! is_array($includs)) {
$includs = (array)$includs;
}
if ( ! is_array($excludes)) {
$excludes = (array)$excludes;
}
if ( ! empty($includs)) {
foreach ($includs as $col) {
$this->selects[$col] = 1;
}
} else {
foreach ($excludes as $col) {
$this->selects[$col] = 0;
}
}
return($this);
}
/**
* where条件查询判断
*
* @usage = $this->mongo_db->where(array('foo' => 'bar'))->get('foobar');
*
*/
public function where($wheres = array()) {
if ( ! is_array($wheres)) {
$wheres = (array)$wheres;
}
if ( ! empty($wheres)) {
foreach($wheres as $wh => $val) {
$this->wheres[$wh] = $val;
}
}
return($this);
}
/**
* where ... in .. 条件查询判断
*
* @usage = $this->mongo_db->where_in('foo', array('bar', 'zoo'))->get('foobar');
*
*/
public function where_in($field = '', $in = array()) {
$this->where_init($field);
$this->wheres[$field]['$in'] = $in;
return($this);
}
/**
* where ... not in .. 条件查询判断
*
* @usage = $this->mongo_db->where_not_in('foo', array('bar', 'zoo'))->get('foobar');
*
*/
public function where_not_in($field = '', $in = array()) {
$this->where_init($field);
$this->wheres[$field]['$nin'] = $in;
return($this);
}
/**
* where ... $field > $x .. 条件查询判断
*
* @usage = $this->mongo_db->where_gt('foo', 20)->get('foobar');
*
*/
public function where_gt($field = '', $x) {
$this->where_init($field);
$this->wheres[$field]['$gt'] = $x;
return($this);
}
/**
* where ... $field >= $x .. 条件查询判断
*
* @usage = $this->mongo_db->where_gte('foo', 20)->get('foobar');
*
*/
public function where_gte($field = '', $x) {
$this->where_init($field);
$this->wheres[$field]['$gte'] = $x;
return($this);
}
/**
* where ... $field < $x .. 条件查询判断
*
* @usage = $this->mongo_db->where_lt('foo', 20)->get('foobar');
*
*/
public function where_lt($field = '', $x) {
$this->where_init($field);
$this->wheres[$field]['$lt'] = $x;
return($this);
}
/**
* where ... $field <= $x .. 条件查询判断
*
* @usage = $this->mongo_db->where_lte('foo', 20)->get('foobar');
*
*/
public function where_lte($field = '', $x) {
$this->where_init($field);
$this->wheres[$field]['$lte'] = $x;
return($this);
}
/**
* where ... $field >= $x AND $field <= $y .. 条件查询判断
*
* @usage = $this->mongo_db->where_between('foo', 20, 30)->get('foobar');
*
*/
public function where_between($field = '', $x, $y) {
$this->where_init($field);
$this->wheres[$field]['$gte'] = $x;
$this->wheres[$field]['$lte'] = $y;
return($this);
}
/**
* where ... $field > $x AND $field < $y .. 条件查询判断
*
* @usage = $this->mongo_db->where_between_ne('foo', 20, 30)->get('foobar');
*
*/
public function where_between_ne($field = '', $x, $y) {
$this->where_init($field);
$this->wheres[$field]['$gt'] = $x;
$this->wheres[$field]['$lt'] = $y;
return($this);
}
/**
* where ... $field <> $x .. 条件查询判断
*
* @usage = $this->mongo_db->where_ne('foo', 20)->get('foobar');
*
*/
public function where_ne($field = '', $x) {
$this->where_init($field);
$this->wheres[$field]['$ne'] = $x;
return($this);
}
/**
* where ... or .. 条件查询判断
*
* @usage = $this->mongo_db->where_or('foo', array('foo', 'bar'))->get('foobar');
*
*/
public function where_or($field = '', $values) {
$this->where_init($field);
$this->wheres[$field]['$or'] = $values;
return($this);
}
/**
* where ... and .. 条件查询判断
*
* @usage = $this->mongo_db->where_and( array ( 'foo' => 1, 'b' => 'someexample' );
*/
public function where_and( $elements_values = array() ) {
foreach ( $elements_values as $element => $val ) {
$this->wheres[$element] = $val;
}
return($this);
}
/**
* where $field % $num = $result
*
* @usage = $this->mongo_db->where_mod( 'foo', 10, 1 );
*/
public function where_mod( $field, $num, $result ) {
$this->where_init($field);
$this->wheres[$field]['$mod'] = array($num, $result);
return($this);
}
/**
* where size
*
* Get the documents where the size of a field is in a given $size int
*
* @usage : $this->mongo_db->where_size('foo', 1)->get('foobar');
*/
public function where_size($field = "", $size = "") {
$this->where_init($field);
$this->wheres[$field]['$size'] = $size;
return ($this);
}
/**
* like条件查询(PHP中定义MongoRegex类实现)
*
* @usage : $this->mongo_db->like('foo', 'bar', 'im', false, false)->get();
*/
public function like($field = "", $value = "", $flags = "i", $enable_start_wildcard = true, $enable_end_wildcard = true) {
$field = (string)$field;
$this->where_init($field);
$value = (string)$value;
$value = quotmeta($value);
if (true !== $enable_start_wildcard) {
$value = "^".$value;
}
if (true !== $enable_end_wildcard) {
$value .= "$";
}
$regex = "/$value/$flags";
$this->wheres[$field] = new MongoRegex($regex);
return($this);
}
/**
* order排序( 1 => ASC, -1 => DESC)
*
* @usage: $this->mongo_db->get_where('foo', array('name' => 'tom'))->order_by(array("age" => 1));
*/
public function order_by($fields = array()) {
foreach($fields as $col => $val) {
if ($val == -1 || $val == false || strtolower($val) == "desc") {
$this->sorts[$col] = -1;
} else {
$this->sorts[$col] = 1;
}
}
return($this);
}
/**
* limit
*
* @usage: $this->mongo_db->get_where('foo', array('name' => 'tom'))->limit(10);
*/
public function limit($x = 999999) {
if ($x !== NULL && is_numeric($x) && $x >= 1) {
$this->limit = (int)$x;
}
return($this);
}
/**
* offset
*
* @usage: $this->mongo_db->get_where('foo', array('name' => 'tom'))->offset(10);
*/
public function offset($x = 0) {
if($x !== NULL && is_numeric($x) && $x >= 1) {
$this->offset = (int) $x;
}
return($this);
}
/**
* get_where
*
* @usage: $this->mongo_db->get_where('foo', array('bar' => 'something'));
*/
public function get_where($collection = "", $where = array(), $limit = 999999) {
return($this->where($where)->limit($limit)->get($collection));
}
/**
* get
*
* @usage: $this->mongo_db->where(array('name' => 'tom'))->get('foo');
*/
public function get($collection) {
if (empty($collection)) {
$this->log_error("In order to retreive documents from MongoDB, a collection name must be passed");
exit;
}
$results = array();
$results = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int)$this->limit)->skip((int)$this->offset)->sort($this->sorts);
$returns = array();
foreach($results as $result) {
$returns[] = $result;
}
$this->clear();
return($returns);
}
/**
* count
*
* @usage: $this->db->get_where('foo', array('name' => 'tom'))->count('foo');
*/
public function count($collection) {
if (empty($collection)) {
$this->log_error("In order to retreive documents from MongoDB, a collection name must be passed");
exit;
}
$count = $this->db->{$collection}->find($this->wheres)->limit((int)$this->limit)->skip((int)$this->offset)->count();
$this->clear();
return($count);
}
/**
* insert
*
* @usage: $this->mongo_db->insert('foo', array('name' => 'tom'));
*/
public function insert($collection = "", $data = array()) {
if (empty($collection)) {
$this->log_error("No Mongo collection selected to delete from");
exit;
}
if (count($data) == 0 || ! is_array($data)) {
$this->log_error("Nothing to insert into Mongo collection or insert is not an array");
exit;
}
try {
$this->db->{$collection}->insert($data, array('fsync' => true));
if (isset($data['_id'])) {
return($data['_id']);
} else {
return(false);
}
} catch(MongoCursorException $e) {
$this->log_error("Insert of data into MongoDB failed: {$e->getMessage()}");
exit;
}
}
/**
* update : 利用MongoDB的 $set 实现
*
* @usage : $this->mongo_db->where(array('name' => 'tom'))->update('foo', array('age' => 24))
*/
public function update($collection = "", $data = array()) {
if (empty($collection)) {
$this->log_error("No Mongo collection selected to delete from");
exit;
}
if (count($data) == 0 || ! is_array($data)) {
$this->log_error("Nothing to update in Mongo collection or update is not an array");
exit;
}
try {
$this->db->{$collection}->update($this->wheres, array('$set' => $data), array('fsync' => true, 'multiple' => false)); //注意: multiple为false
return(true);
} catch(MongoCursorException $e) {
$this->log_error("Update of data into MongoDB failed: {$e->getMessage()}");
exit;
}
}
/**
* update_all : 利用MongoDB的 $set 实现
*
* @usage : $this->mongo_db->where(array('name' => 'tom'))->update_all('foo', array('age' => 24));
*/
public function update_all($collection = "", $data = array()) {
if (empty($collection)) {
$this->log_error("No Mongo collection selected to delete from");
exit;
}
if (count($data) == 0 || ! is_array($data)) {
$this->log_error("Nothing to update in Mongo collection or update is not an array");
exit;
}
try {
$this->db->{$collection}->update($this->wheres, array('$set' => $data), array('fsync' => true, 'multiple' => true)); //注意: multiple为true
return(true);
} catch(MongoCursorException $e) {
$this->log_error("Update of data into MongoDB failed: {$e->getMessage()}");
exit;
}
}
/**
* delete
*
* @usage : $this->mongo_db->where(array('name' => 'tom'))->delete('foo');
*/
public function delete($collection = "") {
if (empty($collection)) {
$this->log_error("No Mongo collection selected to delete from");
exit;
}
try {
$this->db->{$collection}->remove($this->wheres, array('fsync' => true, 'justOne' => true)); //注意justOne为true;
} catch(MongoCursorException $e) {
$this->log_error("Delete of data into MongoDB failed: {$e->getMessage()}");
exit;
}
}
/**
* delete_all
*
* @usage : $this->mongo_db->where(array('name' => 'tom'))->delete_all('foo');
*/
public function delete_all($collection = "") {
if (empty($collection)) {
$this->log_error("No Mongo collection selected to delete from");
exit;
}
try {
$this->db->{$collection}->remove($this->wheres, array('fsync' => true, 'justOne' => false)); //注意justOne为false;
} catch(MongoCursorException $e) {
$this->log_error("Delete of data into MongoDB failed: {$e->getMessage()}");
exit;
}
}
/**
* add_index
*
* @usage : $this->mongo_db->add_index('foo', array('first_name' => 'ASC', 'last_name' => -1), array('unique' => true)));
*/
public function add_index($collection, $keys = array(), $options = array()) {
if (empty($collection)) {
$this->log_error("No Mongo collection specified to add index to");
exit;
}
if (empty($keys) || ! is_array($keys)) {
$this->log_error("Index could not be created to MongoDB Collection because no keys were specified");
exit;
}
foreach($keys as $col => $val) {
if ($val == -1 || $val == false || strtolower($val) == 'desc') {
$keys[$col] = -1;
} else {
$keys[$col] = 1;
}
}
//在此没有对$options数组的有效性进行验证
if (true == $this->db->{$collection}->ensureIndex($keys, $options)) {
$this->clear();
return($this);
} else {
$this->log_error("An error occured when trying to add an index to MongoDB Collection");
exit;
}
}
/**
* remove_index
*
* @usage : $this->mongo_db->remove_index('foo', array('first_name' => 'ASC', 'last_name' => -1))
*/
public function remove_index($collection = "", $keys = array()) {
if (empty($collection)) {
$this->log_error("No Mongo collection specified to add index to");
exit;
}
if (empty($keys) || ! is_array($keys)) {
$this->log_error("Index could not be created to MongoDB Collection because no keys were specified");
exit;
}
if ($this->db->{$collection}->deleteIndex($keys)) {
$this->clear();
return($this);
} else {
$this->log_error("An error occured when trying to add an index to MongoDB Collection");
exit;
}
}
/**
* remove_all_index
*
* @usage : $this->mongo_db->remove_all_index('foo', array('first_name' => 'ASC', 'last_name' => -1))
*/
public function remove_all_index($collection = "", $keys = array()) {
if (empty($collection)) {
$this->log_error("No Mongo collection specified to add index to");
exit;
}
if (empty($keys) || ! is_array($keys)) {
$this->log_error("Index could not be created to MongoDB Collection because no keys were specified");
exit;
}
if ($this->db->{$collection}->deleteIndexes($keys)) {
$this->clear();
return($this);
} else {
$this->log_error("An error occured when trying to add an index to MongoDB Collection");
exit;
}
}
/**
* list_indexes
*
* @usage : $this->mongo_db->list_indexes('foo');
*/
public function list_indexes($collection = "") {
if (empty($collection)) {
$this->log_error("No Mongo collection specified to add index to");
exit;
}
return($this->db->{$collection}->getIndexInfo());
}
/**
* drop_collection
*
* @usage : $this->mongo_db->drop_collection('foo');
*/
public function drop_collection($collection = "") {
if (empty($collection)) {
$this->log_error("No Mongo collection specified to add index to");
exit;
}
$this->db->{$collection}->drop();
return(true);
}
/**
* 生成连接MongoDB 参数字符串
*
*/
private function connection_string() {
include_once($this->mongo_config);
$this->host = trim($config['host']);
$this->port = trim($config['port']);
$this->user = trim($config['user']);
$this->pass = trim($config['pass']);
$this->dbname = trim($config['dbname']);
$this->persist = trim($config['persist']);
$this->persist_key = trim($config['persist_key']);
$connection_string = "mongodb://";
if (empty($this->host)) {
$this->log_error("The Host must be set to connect to MongoDB");
exit;
}
if (empty($this->dbname)) {
$this->log_error("The Database must be set to connect to MongoDB");
exit;
}
if ( ! empty($this->user) && ! empty($this->pass)) {
$connection_string .= "{$this->user}:{$this->pass}@";
}
if ( isset($this->port) && ! empty($this->port)) {
$connection_string .= "{$this->host}:{$this->port}";
} else {
$connection_string .= "{$this->host}";
}
$this->connection_string = trim($connection_string);
}
/**
* 连接MongoDB 获取数据库操作句柄
*
*/
private function connect() {
$options = array();
if (true === $this->persist) {
$options['persist'] = isset($this->persist_key) && ! empty($this->persist_key) ? $this->persist_key : "ci_mongo_persist";
}
try {
$this->connection = new Mongo($this->connection_string, $options);
$this->db = $this->connection->{$this->dbname};
return ($this);
} catch (MongoConnectionException $e) {
$this->log_error("Unable to connect to MongoDB: {$e->getMessage()}");
}
}
/**
* 初始化清理部分成员变量
*
*/
private function clear() {
$this->selects = array();
$this->wheres = array();
$this->limit = NULL;
$this->offset = NULL;
$this->sorts = array();
}
/**
* 依据字段名初始化处理$wheres数组
*
*/
private function where_init($param) {
if ( ! isset($this->wheres[$param])) {
$this->wheres[$param] = array();
}
}
/**
* 错误记录
*
*/
private function log_error($msg) {
$msg = "[Date: ".date("Y-m-i H:i:s")."] ".$msg;
@file_put_contents("./error.log", print_r($msg."\n", true), FILE_APPEND);
}
}
/* End of MyMongo.php */로그인 후 복사
2.mongo_config.php구성 파일:
<?php $config["host"] = "localhost"; $config["user"] = ""; $config["pass"] = ""; $config["port"] = 27017; $config["dbname"] = "test"; $config['persist'] = TRUE; $config['persist_key'] = 'ci_mongo_persist'; /*End of mongo_config.php*/
로그인 후 복사
3.MyMongoDemo.php 파일:
<?php
include_once("MyMongo.php");
$conn = new MyMongo();
//删除所有记录
$conn->delete_all("blog");
//插入第一条记录
$value = array("name" => "小明", "age" => 25, "addr" => array("country" => "中国", "province" => "广西", "city" => "桂林"));
$conn->insert("blog", $value);
var_dump($conn->select(array("name", "age"))->get("blog"));
var_dump($conn->get("blog"));
/* End of MyMongoDemo.php */로그인 후 복사
위 내용은 PHP 작업 MongoDB 클래스 샘플 코드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
AI Hentai Generator
AI Hentai를 무료로 생성하십시오.
인기 기사
R.E.P.O. 에너지 결정과 그들이하는 일 (노란색 크리스탈)
2 몇 주 전
By 尊渡假赌尊渡假赌尊渡假赌
Repo : 팀원을 부활시키는 방법
4 몇 주 전
By 尊渡假赌尊渡假赌尊渡假赌
헬로 키티 아일랜드 어드벤처 : 거대한 씨앗을 얻는 방법
3 몇 주 전
By 尊渡假赌尊渡假赌尊渡假赌
스플릿 소설을이기는 데 얼마나 걸립니까?
3 몇 주 전
By DDD
R.E.P.O. 파일 저장 위치 : 어디에 있고 그것을 보호하는 방법은 무엇입니까?
3 몇 주 전
By DDD
뜨거운 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.
스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
드림위버 CS6
시각적 웹 개발 도구
SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)
뜨거운 주제
Gmail 이메일의 로그인 입구는 어디에 있나요?
7316
9
7316
9
자바 튜토리얼
1625
14
1625
14
Cakephp 튜토리얼
1349
46
1349
46
라라벨 튜토리얼
1261
25
1261
25
PHP 튜토리얼
1208
29
1208
29
CakePHP 프로젝트 구성
Sep 10, 2024 pm 05:25 PM
이번 장에서는 CakePHP의 환경 변수, 일반 구성, 데이터베이스 구성, 이메일 구성에 대해 알아봅니다.
Ubuntu 및 Debian용 PHP 8.4 설치 및 업그레이드 가이드
Dec 24, 2024 pm 04:42 PM
PHP 8.4는 상당한 양의 기능 중단 및 제거를 통해 몇 가지 새로운 기능, 보안 개선 및 성능 개선을 제공합니다. 이 가이드에서는 Ubuntu, Debian 또는 해당 파생 제품에서 PHP 8.4를 설치하거나 PHP 8.4로 업그레이드하는 방법을 설명합니다.
CakePHP 토론
Sep 10, 2024 pm 05:28 PM
CakePHP는 PHP용 오픈 소스 프레임워크입니다. 이는 애플리케이션을 훨씬 쉽게 개발, 배포 및 유지 관리할 수 있도록 하기 위한 것입니다. CakePHP는 강력하고 이해하기 쉬운 MVC와 유사한 아키텍처를 기반으로 합니다. 모델, 뷰 및 컨트롤러 gu
PHP 개발을 위해 Visual Studio Code(VS Code)를 설정하는 방법
Dec 20, 2024 am 11:31 AM
VS Code라고도 알려진 Visual Studio Code는 모든 주요 운영 체제에서 사용할 수 있는 무료 소스 코드 편집기 또는 통합 개발 환경(IDE)입니다. 다양한 프로그래밍 언어에 대한 대규모 확장 모음을 통해 VS Code는
