db = pymongoMongoClient()test
dates = dbuserfind()
print type(dates)
for i in dates:
print ikeys()
break
创建连接,取到dates数据,不就是一个字典列表啊,取一个值然后字典 *** 作keys()不就可以了。
物信息、统计、网页制作、计算等多个领域都体现出了强大的功能。python和其他脚本语言如java、R、Perl 一样,都可以直接在命令行里运行脚本程序。工具/原料
python;CMD命令行;windows *** 作系统
方法/步骤
1、首先下载安装python,建议安装27版本以上,30版本以下,由于30版本以上不向下兼容,体验较差。
2、打开文本编辑器,推荐editplus,notepad等,将文件保存成 py格式,editplus和notepad支持识别python语法。
脚本第一行一定要写上 #!usr/bin/python
表示该脚本文件是可执行python脚本
如果python目录不在usr/bin目录下,则替换成当前python执行程序的目录。
3、编写完脚本之后注意调试、可以直接用editplus调试。调试方法可自行百度。脚本写完之后,打开CMD命令行,前提是python 已经被加入到环境变量中,如果没有加入到环境变量,请百度
4、在CMD命令行中,输入 “python” + “空格”,即 ”python “;将已经写好的脚本文件拖拽到当前光标位置,然后敲回车运行即可。
MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可护展的高性能数据存储解决方案。它的特点是高性能、易部署、易使用,存储数据非常方便。
MongoDB 简单使用
联接数据库
复制代码代码如下:
In [1]: import pymongo
In [2]: from pymongo import Connection
In [3]: connection = Connection('19216813', 27017) //创建联接
Connection 相关参数
复制代码代码如下:
Connection([host='localhost'[, port=27017[, pool_size=None[, auto_start_request=None[, timeout=None[, slave_okay=False[, network_timeout=None[, document_class=dict[, tz_aware=True]]]]]]]]])
数据库 *** 作
复制代码代码如下:
In [9]: cdatabase_names() //列出所有数据库名称
Out[9]: [u'test', u'admin', u'yuhen', u'sms', u'local']
In [10]: cserver_info() //查看服务器相关信息
Out[10]:
{u'bits': 64,
u'gitVersion': u'nogitversion',
u'ok': 10,
u'sysInfo': u'Linux yellow 2624-27-server #1 SMP Fri Mar 12 01:23:09 UTC 2010 x86_64 BOOST_LIB_VERSION=1_40',
u'version': u'122'}
In [16]: db = c['test'] //选择数据库
In [17]: dbcollection_names() //列出当前数据库中所有集合名称
Out[17]: [u'systemindexes', u'fsfiles', u'fschunks', u'test_gao']
In [23]: dbconnection //查看联接信息
Out[23]: Connection('19216813', 27017)
In [24]: dbcreate_collection('test_abeen') //创建新集合
Out[24]: Collection(Database(Connection('19216813', 27017), u'test'), u'test_abeen')
In [25]: dblast_status() //查看上次 *** 作状态
Out[25]: {u'err': None, u'n': 0, u'ok': 10}
In [26]: dbname //查看当前数据库名称
Out[26]: u'test'
In [27]: dbprofiling_info() //查看配置信息
Out[27]: []
In [28]: dbprofiling_level()
Out[28]: 00
集合 *** 作
复制代码代码如下:
In [31]: dbcollection_names() //查看当前数据库所有集合名称
Out[31]:
[u'systemindexes',
u'fsfiles',
u'fschunks',
u'test_gao',
u'systemusers',
u'test_abeen']
In [32]: c = dbtest_abeen //选择集合
In [33]: cname //查看当前集合名称
Out[33]: u'test_abeen'
In [35]: cfull_name //查看当前集合全名
Out[35]: u'testtest_abeen'
In [36]: cdatabase //查看当前集合数据库相关信息
Out[36]: Database(Connection('19216813', 27017), u'test')
In [38]: post = {"author":"Mike","text":"this is a test by abeen"}
In [39]: posts = dbposts
In [40]: postsinsert(post) //向数据库集合插入文档,默认创建集合
Out[40]: ObjectId('4c358492421aa91e70000000')
In [41]: dbcollection_names() //显示所有集合名称
Out[41]:
[u'systemindexes',
u'fsfiles',
u'fschunks',
u'test_gao',
u'systemusers',
u'test_abeen',
u'posts']
In [42]: postsfind_one() //从集合查找信息
Out[42]:
{u'_id': ObjectId('4c358492421aa91e70000000'),
u'author': u'Mike',
u'text': u'this is a test by abeen'}
In [52]: pupdate({"author":"Mike"},{"$set":{"author":"abeen","text":"this is a test by abeen shan shan"}})//更新集合文档信息
In [55]: list(pfind())
Out[55]:
[{u'_id': ObjectId('4c358492421aa91e70000000'),
u'author': u'abeen',
u'text': u'this is a test by abeen shan shan'}]
In [96]: list(postsfind())
Out[96]:
[{u'_id': ObjectId('4c358492421aa91e70000000'),
u'author': u'Mike',
u'text': u'this is a test by abeen'},
{u'_id': ObjectId('4c358ad4421aa91e70000002'), u'a': u'aa', u'b': u'bb'},
{u'_id': ObjectId('4c358ad9421aa91e70000003'), u'a': u'aa', u'b': u'bb'},
{u'_id': ObjectId('4c358abb421aa91e70000001'),
u'a': u'abeen',
u'b': u'this bb is updated'}]
In [97]: postsremove({"a":"abeen"}) //删除符合条件的文档
In [98]: list(postsfind())
Out[98]:
[{u'_id': ObjectId('4c358492421aa91e70000000'),
u'author': u'Mike',
u'text': u'this is a test by abeen'},
{u'_id': ObjectId('4c358ad4421aa91e70000002'), u'a': u'aa', u'b': u'bb'},
{u'_id': ObjectId('4c358ad9421aa91e70000003'), u'a': u'aa', u'b': u'bb'}]
In [102]: dbcollection_names()
Out[102]:
[u'systemindexes',
u'fsfiles',
u'fschunks',
u'test_gao',
u'systemusers',
u'test_abeen',
u'posts',
u'doc_abeen']
In [104]: dbdrop_collection("doc_abeen") //删除集合
In [105]: dbcollection_names()
Out[105]:
[u'systemindexes',
u'fsfiles',
u'fschunks',
u'test_gao',
u'systemusers',
u'test_abeen',
u'posts']
代码
复制代码代码如下:
In [113]: result = dbpostsfind({"a":"aa"})//查找
In [114]: type(result)
Out[114]: <class 'pymongocursorCursor'>
In [119]: list(result)
Out[119]:
[{u'_id': ObjectId('4c358ad4421aa91e70000002'), u'a': u'aa', u'b': u'bb'},
{u'_id': ObjectId('4c358ad9421aa91e70000003'), u'a': u'aa', u'b': u'bb'}]
find格式
复制代码代码如下:
find([spec=None[, fields=None[, skip=0[, limit=0[, timeout=True[, snapshot=False[, tailable=False[, sort=None[, max_scan=None[, as_class=None[, kwargs]]]]]]]]]]])
代码
复制代码代码如下:
In [120]: dbpostscount()//当前集合文档数
Out[120]: 3
In [121]: type(dbposts)
Out[121]: <class 'pymongocollectionCollection'>
In [138]: postsrename('test_abeen')//重命名当前集合
In [139]: dbcollection_names()
Out[139]:
[u'systemindexes',
u'fsfiles',
u'fschunks',
u'test_gao',
u'systemusers',
u'test_abeen']
In [151]: for post in cfind({"a":"aa"})sort("a"): //查询并排序列
post
Out[152]: {u'_id': ObjectId('4c358ad4421aa91e70000002'), u'a': u'aa', u'b': u'bb'}
Out[152]: {u'_id': ObjectId('4c358ad9421aa91e70000003'), u'a': u'aa', u'b': u'bb'}
复制代码代码如下:
> dbfooinsert( { x : 1, y : 1 } )
> dbfooinsert( { x : 2, y : "string" } )
> dbfooinsert( { x : 3, y : null } )
> dbfooinsert( { x : 4 } )
// Query #1 y 为null或不存在
> dbfoofind( { "y" : null } )
{ "_id" : ObjectId("4dc1975312c677fc83b5629f"), "x" : 3, "y" : null }
{ "_id" : ObjectId("4dc1975a12c677fc83b562a0"), "x" : 4 }
// Query #2 y为null的值
> dbfoofind( { "y" : { $type : 10 } } )
{ "_id" : ObjectId("4dc1975312c677fc83b5629f"), "x" : 3, "y" : null }
// Query #3 y不存在的结果
> dbfoofind( { "y" : { $exists : false } } )
{ "_id" : ObjectId("4dc1975a12c677fc83b562a0"), "x" : 4 }
以上就是关于如何使用python获取mongoDB数据库中表格的字段名全部的内容,包括:如何使用python获取mongoDB数据库中表格的字段名、请问如何用python将爬取的数据逐条传入MongoDB数据库,请大牛指点。、python3 mongodb怎么实现关联查询等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)