DataSourceClient
Path
com.roma.apic.livedata.client.v1.DataSourceClient
Description
This class is used to connect to data sources and run SQL statements, stored procedures, or NoSQL query statements.
Example
importClass(com.roma.apic.livedata.client.v1.DataSourceClient); importClass(com.roma.apic.livedata.config.v1.DataSourceConfig); function execute(data){ var config = new DataSourceConfig() config.setType("mysql") config.setUrl("jdbc:mysql://127.0.0.1:3306/db?allowPublicKeyRetrieval=true") config.setUser("username") config.setPassword("password") var ds = new DataSourceClient(config) return ds.execute("SELECT * FROM person where name = ? and age = ?", "Tom", 20); }
importClass(com.roma.apic.livedata.client.v1.DataSourceClient); importClass(com.roma.apic.livedata.config.v1.DataSourceConfig); function execute(data){ var config = new DataSourceConfig() config.setType("oracle") config.setUrl("jdbc:oracle:thin:@127.0.0.1:1521/db") config.setUser("username") config.setPassword("password") var ds = new DataSourceClient(config) return ds.execute("select table_name from user_tables"); }
NoSQL data source example:
importClass(com.roma.apic.livedata.client.v1.DataSourceClient); importClass(com.roma.apic.livedata.config.v1.DataSourceConfig); function execute(data){ var config = new DataSourceConfig() config.setType("redis") config.setUrl("127.0.0.1:6379") config.setPassword("password") var ds = new DataSourceClient(config) return ds.execute("GET key"); }
Constructor Details
public DataSourceClient(DataSourceConfig config)
Import the data source configuration and construct a data source connector.
Method List
Returned Type |
Method and Description |
---|---|
Object |
execute(String sql, Object... prepareValue) Run SQL statements, stored procedures, or NoSQL query statements. |
Method Details
public Object execute(String sql, Object... prepareValue)
Run SQL statements, stored procedures, or NoSQL query statements.
Input Parameter
prepareValue: This parameter is valid only in SQL statements and is used to replace "?" in SQL statements to prevent SQL injection.
Returns
Statement execution results
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot