connection examples (WIP)

examples/connection/connect.py

@@ -0,0 +1,15 @@
+from twisted.internet import defer
+from twisted.internet.task import react
+from txmongo.connection import ConnectionPool
+
+
+@defer.inlineCallbacks
+def main(reactor):
+    # default pool_size is 1
+    mongo_conn = ConnectionPool("mongodb://localhost:27017/", pool_size=4)
+
+    yield mongo_conn.test.hobbits.insert({"name": "Frodo"})
+    yield mongo_conn.disconnect()
+
+
+react(main)

examples/connection/connect_options.py

@@ -0,0 +1,27 @@
+from twisted.internet import defer
+from twisted.internet.task import react
+from txmongo.connection import ConnectionPool
+
+
+@defer.inlineCallbacks
+def replicaset():
+    conn = ConnectionPool("mongodb://localhost:27017/?replicaSet=rs0")
+    yield conn.test.fruits.insert({"kind": "Pear"})
+    yield conn.disconnect()
+
+
+@defer.inlineCallbacks
+def read_preference():
+    conn = ConnectionPool("mongodb://localhost:27017/?readPreference=secondary")
+    fruits = yield conn.test.fruits.find()
+    print(fruits)
+    yield conn.disconnect()
+
+
+@defer.inlineCallbacks
+def main(reactor):
+    yield replicaset()
+    yield read_preference()
+
+
+react(main)