Add table creation in docstring examples

Author: beijiez

instrumentation/opentelemetry-instrumentation-aiopg/src/opentelemetry/instrumentation/aiopg/__init__.py

@@ -30,6 +30,7 @@
 
     cnx = await aiopg.connect(database='Database')
     cursor = await cnx.cursor()
+    await cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     await cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
@@ -38,6 +39,7 @@
 
     cnx = await pool.acquire()
     cursor = await cnx.cursor()
+    await cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     await cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
@@ -51,6 +53,7 @@
     cnx = await aiopg.connect(database='Database')
     instrumented_cnx = AiopgInstrumentor().instrument_connection(cnx)
     cursor = await instrumented_cnx.cursor()
+    await cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     await cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     instrumented_cnx.close()

instrumentation/opentelemetry-instrumentation-mysql/src/opentelemetry/instrumentation/mysql/__init__.py

@@ -31,6 +31,7 @@
 
     cnx = mysql.connector.connect(database="MySQL_Database")
     cursor = cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
@@ -44,6 +45,7 @@
     cnx = mysql.connector.connect(database="MySQL_Database")
     instrumented_cnx = MySQLInstrumentor().instrument_connection(cnx)
     cursor = instrumented_cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     instrumented_cnx.close()

instrumentation/opentelemetry-instrumentation-mysqlclient/src/opentelemetry/instrumentation/mysqlclient/__init__.py

@@ -51,6 +51,7 @@
 
     cnx = MySQLdb.connect(database="MySQL_Database")
     cursor = cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)"
     cnx.commit()
     cursor.close()
@@ -73,6 +74,7 @@
         }
     )
     cursor = instrumented_cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)"
     instrumented_cnx.commit()
     cursor.close()

instrumentation/opentelemetry-instrumentation-psycopg/src/opentelemetry/instrumentation/psycopg/__init__.py

@@ -94,6 +94,7 @@
     cnx = psycopg.connect(database='Database')
 
     cursor = cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
@@ -107,6 +108,7 @@
     cnx = psycopg.connect(database='Database')
     instrumented_cnx = PsycopgInstrumentor().instrument_connection(cnx)
     cursor = instrumented_cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     instrumented_cnx.close()

instrumentation/opentelemetry-instrumentation-psycopg2/src/opentelemetry/instrumentation/psycopg2/__init__.py

@@ -94,6 +94,7 @@
     cnx = psycopg2.connect(database='Database')
 
     cursor = cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
@@ -107,6 +108,7 @@
     cnx = psycopg2.connect(database='Database')
     instrumented_cnx = Psycopg2Instrumentor().instrument_connection(cnx)
     cursor = instrumented_cnx.cursor()
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     instrumented_cnx.close()

instrumentation/opentelemetry-instrumentation-sqlite3/src/opentelemetry/instrumentation/sqlite3/__init__.py

@@ -32,7 +32,7 @@
 
     cnx = sqlite3.connect(':memory:')
     cursor = cnx.cursor()
-    cursor.execute("CREATE TABLE test (testField INTEGER)")
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
@@ -46,7 +46,7 @@
     conn = sqlite3.connect(":memory:")
     instrumented_connection = SQLite3Instrumentor().instrument_connection(conn)
     cursor = instrumented_connection.cursor()
-    cursor.execute("CREATE TABLE test (testField INTEGER)")
+    cursor.execute("CREATE TABLE IF NOT EXISTS test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.execute("SELECT * FROM test")
     cursor.close()