Doris Python Driver Usage (Installation and Usage)
1. Install python-doris driver
To use Doris's Python driver, you need to install the Python driver first. You can install it using the following command:
*
pip3 install python-doris
2. Configure Doris connection pool
In the Python driver, you need to configure Doris's connection pool. You can configure it using the following command:
import doris
# Set Doris connection information
doris_config = {
"url": "127.0.0.1:20300", # Doris service address
"user": "your_username", # Your username for authentication
"password": "your_password" # Your password for authentication
}
# Connect to Doris service
conn = doris.DorisClient(doris_config)
# Execute SQL statements using the connection pool
result = conn.execute_query("SELECT * FROM your_table_name")
3. Execute SQL statements with Doris driver
In the Python driver, you can use the conn.execute_query() method to execute SQL statements with the Doris driver.
import doris
# Set Doris connection information
doris_config = {
"url": "127.0.0.1:20300", # Doris service address
"user": "your_username", # Your username for authentication
"password": "your_password" # Your password for authentication
}
# Connect to Doris service
conn = doris.DorisClient(doris_config)
# Execute SQL statement
result = conn.execute_query("SELECT * FROM your_table_name")
4. Process driver results
In the Python driver, you need to process the results from the driver. You can process them using the following methods:
import doris
# Set Doris connection information
doris_config = {
"url": "127.0.0.1:20300", # Doris service address
"user": "your_username", # Your username for authentication
"password": "your_password" # Your password for authentication
}
# Connect to Doris service
conn = doris.DorisClient(doris_config)
# Execute SQL statement
result = conn.execute_query("SELECT * FROM your_table_name")
# Process driver results
for row in result:
print(row)
5. Close connection pool
In the Python driver, you need to close the connection pool. You can close it using the following methods:
import doris
# Set Doris connection information
doris_config = {
"url": "127.0.0.1:20300", # Doris service address
"user": "your_username", # Your username for authentication
"password": "your_password" # Your password for authentication
}
# Connect to Doris service
conn = doris.DorisClient(doris_config)
# Execute SQL statement
result = conn.execute_query("SELECT * FROM your_table_name")
# Close connection pool
conn.close()