-
Notifications
You must be signed in to change notification settings - Fork 61
Expand file tree
/
Copy pathPutRow.py
More file actions
47 lines (37 loc) · 1.58 KB
/
PutRow.py
File metadata and controls
47 lines (37 loc) · 1.58 KB
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
import jpype
jpype.startJVM(classpath=["./gridstore.jar", "./gridstore-arrow.jar"])
import griddb_python as griddb
import sys
factory = griddb.StoreFactory.get_instance()
argv = sys.argv
try:
# Get GridStore object
gridstore = factory.get_store(host=argv[1], port=int(argv[2]), cluster_name=argv[3], username=argv[4], password=argv[5])
# When operations such as container creation and acquisition are performed, it is connected to the cluster.
gridstore.get_container("containerName")
print("Connect to Cluster")
# Create Collection
conInfo = griddb.ContainerInfo(name="SamplePython_PutRow",
column_info_list=
[["id", griddb.Type.INTEGER],
["productName", griddb.Type.STRING],
["count", griddb.Type.INTEGER]],
type=griddb.ContainerType.COLLECTION,
row_key=True)
col = gridstore.put_container(conInfo)
print("Create Collection name=SamplePython_PutRow")
# Register a row
# (1)Get the container
col1 = gridstore.get_container("SamplePython_PutRow")
if col1 == None:
print( "ERROR Container not found. name=SamplePython_PutRow")
# (2)Register the row
col1.put([0, "display", 150])
print("Put Row")
print("success!")
except griddb.GSException as e:
for i in range(e.get_error_stack_size()):
print("[", i, "]")
print(e.get_error_code(i))
print(e.get_location(i))
print(e.get_message(i))