php实现的mongodb操作类

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

<?php

/**

* Created by PhpStorm.

* User: yangyulong

* Date: 2015/5/26

* Time: 13:45

*/

class Mongo_db

{

private static $instanceof = NULL;

public $mongo;

private $host = 'localhost';

private $port = '27017';

private $db;

public $dbname;

private $table = NULL;

/**

* 初始化类，得到mongo的实例对象

*/

public function __construct($host = NULL, $port = NULL, $dbname = NULL, $table = NULL)

{

if (NULL === $dbname) {

$this->throwError('集合不能为空！');

}

//判断是否传递了host和port

if (NULL !== $host) {

$this->host = $host;

}

if (NULL !== $port) {

$this->port = $port;

}

$this->table = $table;

$this->mongo = new MongoClient($this->host . ':' . $this->port);

if ($this->getVersion() >= '0.9.0') {

$this->dbname = $this->mongo->selectDB($dbname);

$this->db = $this->dbname->selectCollection($table);

} else {

$this->db = $this->mongo->$dbname->$table;

}

}

public function getVersion()

{

return MongoClient::VERSION;

}

/**

* 单例模式

* @return Mongo|null

*/

//public static function getInstance($host=null, $port=null, $dbname=null, $table=null){

//

// if(!(self::$instanceof instanceof self)){

// self::$instanceof = new self($host, $port, $dbname, $table);

// }

//

// return self::$instanceof;

//}

/**

* 插入一条数据

* @param array $doc

*/

public function insert($doc = array())

{

if (empty($doc)) {

$this->throwError('插入的数据不能为空！');

}

//保存数据信息

try {

if (!$this->db->insert($doc)) {

throw new MongoException('插入数据失败');

}

} catch (MongoException $e) {

$this->throwError($e->getMessage());

}

}

/**

* 插入多条数据信息

* @param array $doc

*/

public function insertMulti($doc = array())

{

if (empty($doc)) {

$this->throwError('插入的数据不能为空！');

}

//插入数据信息

foreach ($doc as $key => $val) {

//判断$val是不是数组

if (is_array($val)) {

$this->insert($val);

}

}

}

/**

* 查找一条记录

* @return array|null

*/

public function findOne($where = NULL)

{

if (NULL === $where) {

try {

if ($result = $this->db->findOne()) {

return $result;

} else {

throw new MongoException('查找数据失败');

}

} catch (MongoException $e) {

$this->throwError($e->getMessage());

}

} else {

try {

if ($result = $this->db->findOne($where)) {

return $result;

} else {

throw new MongoException('查找数据失败');

}

} catch (MongoException $e) {

$this->throwError($e->getMessage());

}

}

}

/**

* todo 带条件的随后做

* 查找所有的文档

* @return MongoCursor

*/

public function find($where = NULL)

{

if (NULL === $where) {

try {

if ($result = $this->db->find()) {

} else {

throw new MongoException('查找数据失败');

}

} catch (MongoException $e) {

$this->throwError($e->getMessage());

}

} else {

try {

if ($result = $this->db->find($where)) {

} else {

throw new MongoException('查找数据失败');

}

} catch (MongoException $e) {

$this->throwError($e->getMessage());

}

}

$arr = array();

foreach ($result as $id => $val) {

$arr[] = $val;

}

return $arr;

}

/**

* 获取记录条数

* @return int

*/

public function getCount()

{

try {

if ($count = $this->db->count()) {

return $count;

} else {

throw new MongoException('查找总数失败');

}

} catch (MongoException $e) {

$this->throwError($e->getMessage());

}

}

/**

* 获取所有的数据库

* @return array

*/

public function getDbs()

{

return $this->mongo->listDBs();

}

/**

* 删除数据库

* @param null $dbname

* @return mixed

*/

public function dropDb($dbname = NULL)

{

if (NULL !== $dbname) {

$retult = $this->mongo->dropDB($dbname);

if ($retult['ok']) {

return TRUE;

} else {

return FALSE;

}

}

$this->throwError('请输入要删除的数据库名称');

}

/**

* 强制关闭数据库的链接

*/

public function closeDb()

{

$this->mongo->close(TRUE);

}

/**

* 输出错误信息

* @param $errorInfo 错误内容

*/

public function throwError($errorInfo='')

{

echo "<h3>出错了：$errorInfo</h3>";

die();

}

}