Skip to content
Branch: master
Find file History
Matt Ellis Matt Ellis
Matt Ellis and Matt Ellis adding header to READMEs for doc site
Latest commit a3af1dd May 14, 2019
Permalink
Type Name Latest commit message Commit time
..
Failed to load latest commit information.
util add DbHelper Apr 17, 2019
README.md adding header to READMEs for doc site May 14, 2019
activity.go add DbHelper Apr 17, 2019
activity_test.go minor cleanup Apr 24, 2019
descriptor.json update version; go.mods May 6, 2019
go.mod update go.mods May 13, 2019
go.sum update go.mods May 13, 2019
metadata.go initial commit for sqlquery activity Apr 12, 2019

README.md

SQLQuery Database Activity

This activity provides your flogo application execute database queries.

Installation

flogo install github.com/project-flogo/activity/sqlquery

Configuration

Settings:

Name Type Description
dbType string The type of database (mysql, oracle, postres, sqlite, sqlserver) - REQUIRED
driverName string The database driver name - REQUIRED
dataSourceName string The database DataSource name - REQUIRED
maxOpenConnections int Max open connections (default is unlimited)
maxIdleConnections int Max idle connections (default is 2)
query string The SQL select query - REQUIRED
disablePrepared bool Disable prepared statement usage
labeledResults bool Return results labeled by column name

Input:

Name Type Description
params map The query parameters

Output:

Name Type Description
columnNames array The names of the result columns
results array The results

Examples

Query

Simple query that gets all items with ID less than 10, retrieves all the columns. In order to use mysql, you have to import the driver by adding github.com/go-sql-driver/mysql to the app imports section. See github.com/go-sql-driver/mysql for more information on the driver.

{
  "id": "dbquery",
  "name": "DbQuery",
  "activity": {
    "ref": "github.com/project-flogo/contrib/activity/sqlquery",
    "settings": {
      "dbType": "mysql",
      "driverName": "mysql",
      "dataSourceName": "username:password@tcp(host:port)/dbName",
      "query": "select * from test where ID < 10"
    }
  }
}

Named Query

Query with parameters. Parameters are referenced using ':', e.g. :id, regardless of database

{
  "id": "named_dbquery",
  "name": "Named DbQuery",
  "activity": {
    "ref": "github.com/project-flogo/contrib/activity/sqlquery",
    "settings": {
      "dbType": "mysql",
      "driverName": "mysql",
      "dataSourceName": "username:password@tcp(host:port)/dbName",
      "query": "select * from test where ID < :id"
    },
    "input": {
      "params": {
        "id":10
      }
    }
  }
}

Supported Drivers

You can’t perform that action at this time.