summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/examples/python
diff options
context:
space:
mode:
authorRamon Fernandez <ramon@mongodb.com>2016-01-27 17:17:17 -0500
committerRamon Fernandez <ramon@mongodb.com>2016-01-27 17:17:21 -0500
commit90118b147a6943b19dc929862a11071538db1438 (patch)
treed1e2c409595332174953e7dbe2db262935d89ae5 /src/third_party/wiredtiger/examples/python
parentb8cad6a59cbce2831e69e6b94f9544d83d6e00b0 (diff)
downloadmongo-90118b147a6943b19dc929862a11071538db1438.tar.gz
Import wiredtiger-wiredtiger-2.7.0-505-g7fea169.tar.gz from wiredtiger branch mongodb-3.4
ref: 44463c5..7fea169 WT-2355 Fix minor scratch buffer usage in logging. WT-2348 xargs -P isn't portable WT-2347 Java: schema format edge cases WT-2344 OS X compiler warning WT-2342 Enhance wtperf to support background create and drop operations WT-2340 Add logging guarantee assertions, whitespace WT-2339 format post-rebalance verify failure (stress run #11586) WT-2338 Disable using pre-allocated log files when backup cursor is open WT-2335 NULL pointer crash in config_check_search with invalid configuration string WT-2333 Add a flag so drop doesn't block WT-2332 Bug in logging write-no-sync mode WT-2331 Checking of search() result for reference cursors before join() WT-2328 schema drop does direct unlink, it should use a block manager interface. WT-2326 Change WTPERF to use new memory allocation functions instead of the standard WT-2321 WT-2321: race between eviction and worker threads on the eviction queue WT-2320 Only check copyright when cutting releases WT-2316 stress test failure: WT_CURSOR.prev out-of-order returns WT-2314 page-swap error handling is inconsistent WT-2313 sweep-server: conn_dhandle.c, 610: dhandle != conn->cache->evict_file_next WT-2312 re-creating a deleted column-store page can corrupt the in-memory tree WT-2308 custom extractor for ref_cursors in join cursor WT-2305 Fix coverity scan issues on 23/12/2015 WT-2296 New log algorithm needs improving for sync/flush settings WT-2295 WT_SESSION.create does a full-scan of the main table WT-2287 WT_SESSION.rebalance WT-2275 broken DB after application crash WT-2267 Improve wtperf throttling implementation to provide steady load WT-2247 variable-length column-store in-memory page splits WT-2242 WiredTiger treats dead trees the same as other trees in eviction WT-2142 Connection cleanup in Python tests WT-2073 metadata cleanups WT-1801 Add a directory sync after rollback of a WT_SESSION::rename operation WT-1517 schema format edge cases SERVER-22064 Coverity analysis defect 77699: Unchecked return value SERVER-21619 sys-perf: WT crash during core_workloads_WT execution
Diffstat (limited to 'src/third_party/wiredtiger/examples/python')
-rwxr-xr-xsrc/third_party/wiredtiger/examples/python/ex_access.py55
-rwxr-xr-xsrc/third_party/wiredtiger/examples/python/ex_stat.py109
2 files changed, 164 insertions, 0 deletions
diff --git a/src/third_party/wiredtiger/examples/python/ex_access.py b/src/third_party/wiredtiger/examples/python/ex_access.py
new file mode 100755
index 00000000000..aa99c1f6547
--- /dev/null
+++ b/src/third_party/wiredtiger/examples/python/ex_access.py
@@ -0,0 +1,55 @@
+#!/usr/bin/env python
+#
+# Public Domain 2014-2016 MongoDB, Inc.
+# Public Domain 2008-2014 WiredTiger, Inc.
+#
+# This is free and unencumbered software released into the public domain.
+#
+# Anyone is free to copy, modify, publish, use, compile, sell, or
+# distribute this software, either in source code form or as a compiled
+# binary, for any purpose, commercial or non-commercial, and by any
+# means.
+#
+# In jurisdictions that recognize copyright laws, the author or authors
+# of this software dedicate any and all copyright interest in the
+# software to the public domain. We make this dedication for the benefit
+# of the public at large and to the detriment of our heirs and
+# successors. We intend this dedication to be an overt act of
+# relinquishment in perpetuity of all present and future rights to this
+# software under copyright law.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+# EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+# MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
+# IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR
+# OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
+# ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
+# OTHER DEALINGS IN THE SOFTWARE.
+#
+
+import os
+from wiredtiger import wiredtiger_open
+
+# Connect to the database and open a session
+os.system('rm -rf WT_HOME')
+os.makedirs('WT_HOME')
+
+conn = wiredtiger_open('WT_HOME', 'create')
+session = conn.open_session()
+
+# Create a simple table
+session.create('table:T', 'key_format=S,value_format=S')
+
+# Open a cursor and insert a record
+cursor = session.open_cursor('table:T', None)
+
+cursor.set_key('key1')
+cursor.set_value('value1')
+cursor.insert()
+
+# Iterate through the records
+cursor.reset()
+for key, value in cursor:
+ print('Got record: %s : %s' % (key, value))
+
+conn.close()
diff --git a/src/third_party/wiredtiger/examples/python/ex_stat.py b/src/third_party/wiredtiger/examples/python/ex_stat.py
new file mode 100755
index 00000000000..10f1d6d597c
--- /dev/null
+++ b/src/third_party/wiredtiger/examples/python/ex_stat.py
@@ -0,0 +1,109 @@
+#!/usr/bin/env python
+#
+# Public Domain 2014-2016 MongoDB, Inc.
+# Public Domain 2008-2014 WiredTiger, Inc.
+#
+# This is free and unencumbered software released into the public domain.
+#
+# Anyone is free to copy, modify, publish, use, compile, sell, or
+# distribute this software, either in source code form or as a compiled
+# binary, for any purpose, commercial or non-commercial, and by any
+# means.
+#
+# In jurisdictions that recognize copyright laws, the author or authors
+# of this software dedicate any and all copyright interest in the
+# software to the public domain. We make this dedication for the benefit
+# of the public at large and to the detriment of our heirs and
+# successors. We intend this dedication to be an overt act of
+# relinquishment in perpetuity of all present and future rights to this
+# software under copyright law.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+# EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+# MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
+# IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR
+# OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
+# ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
+# OTHER DEALINGS IN THE SOFTWARE.
+#
+# ex_stat.py
+# This is an example demonstrating how to query database statistics.
+
+import os
+from wiredtiger import wiredtiger_open,WIREDTIGER_VERSION_STRING,stat
+
+
+def main():
+ # Create a clean test directory for this run of the test program
+ os.system('rm -rf WT_HOME')
+ os.makedirs('WT_HOME')
+ # Connect to the database and open a session
+ conn = wiredtiger_open('WT_HOME', 'create,statistics=(all)')
+ session = conn.open_session()
+
+ # Create a simple table
+ session.create('table:access', 'key_format=S,value_format=S')
+
+ # Open a cursor and insert a record
+ cursor = session.open_cursor('table:access', None)
+
+ cursor['key'] = 'value'
+ cursor.close()
+
+ session.checkpoint()
+ print WIREDTIGER_VERSION_STRING
+ print_database_stats(session)
+ print_file_stats(session)
+ print_overflow_pages(session)
+ print_derived_stats(session)
+ conn.close()
+
+
+def print_database_stats(session):
+ statcursor = session.open_cursor("statistics:")
+ print_cursor(statcursor)
+ statcursor.close()
+
+
+def print_file_stats(session):
+ fstatcursor = session.open_cursor("statistics:table:access")
+ print_cursor(fstatcursor)
+ fstatcursor.close()
+
+
+def print_overflow_pages(session):
+ ostatcursor = session.open_cursor("statistics:table:access")
+ val = ostatcursor[stat.dsrc.btree_overflow]
+ if val != 0:
+ print '%s=%s' % (str(val[0]), str(val[1]))
+ ostatcursor.close()
+
+
+def print_derived_stats(session):
+ dstatcursor = session.open_cursor("statistics:table:access")
+ ckpt_size = dstatcursor[stat.dsrc.block_checkpoint_size][1]
+ file_size = dstatcursor[stat.dsrc.block_size][1]
+ percent = 0
+ if file_size != 0:
+ percent = 100 * ((float(file_size) - float(ckpt_size)) / float(file_size))
+ print "Table is %%%s fragmented" % str(percent)
+
+ app_insert = int(dstatcursor[stat.dsrc.cursor_insert_bytes][1])
+ app_remove = int(dstatcursor[stat.dsrc.cursor_remove_bytes][1])
+ app_update = int(dstatcursor[stat.dsrc.cursor_update_bytes][1])
+ fs_writes = int(dstatcursor[stat.dsrc.cache_bytes_write][1])
+
+ if app_insert + app_remove + app_update != 0:
+ print "Write amplification is " + '{:.2f}'.format(fs_writes / (app_insert + app_remove + app_update))
+ dstatcursor.close()
+
+
+def print_cursor(mycursor):
+ while mycursor.next() == 0:
+ val = mycursor.get_value()
+ if val[1] != '0':
+ print '%s=%s' % (str(val[0]), str(val[1]))
+
+if __name__ == "__main__":
+ main()
+