C#

string queryString = "select * from bbb where A1=:A1 and B1=:B1";

       public OracleParameter[] GetSqlParameters(string[] fields, object[] obj)

        {
            try
            {
                OracleParameter[] parameters = new OracleParameter[obj.Count()];
                for (int i = 0; i < obj.Count(); i++)
                {
                    parameters[i] = new OracleParameter(fields[i], obj[i]);
                }
                return parameters;
            }
            catch
            {
                return new OracleParameter[] { };
            }
        }

var edge = require('edge');
var http = require('http');
var port = process.env.PORT || 8088;


var userRepository = {
        getUsers: edge.func({
            assemblyFile:'Edge.Test.dll',
            typeName: 'Edge.Test.DataConnector',
            methodName: 'Invoke'
        })
};

function logError(error, response){
    console.log('[Error]:{' + error+'}');
    response.writeHead(200, { 'Content-Type': 'text/plain'});
    response.write('[Error]:' + error);
    response.end("");
}

http.createServer(function(request,response){
    console.log('Creating Server...');
    response.writeHead(200, {'Content-Type':'text/html'});
    var payload = {};
    console.log('[Before][userRepository.getUsers]');
    userRepository.getUsers(payload, function(error, result){
        console.log('[Result][userRepository.getUsers]');
        if(error){logError(error, result);return;}
        if(result){
            response.write("<ul>");
            result.forEach(function(user){
                console.log("[Response contains User]{"+user.FirstName+"|"+user.LastName+"}");
                response.write("<li>" + user.FirstName + " " + user.LastName);
            });

            response.end("</ul>");
        }
        else{
            response.end("No users found");
        }
    });
}).listen(port);

console.log("Node server listening on port: " + port);

public async Task<object> Invoke(object input)
        {
            var payload = (IDictionary<string, object>)input;
            return await GetUsers();
        }
        public async Task<List<Data.User>> GetUsers()
        {
            TaskCompletionSource<List<Data.User>> source = new TaskCompletionSource<List<Data.User>>();
            Task<List<Data.User>> task = source.Task;

            var connector = new Data.SqlServer();

            Task.Factory.StartNew(() =>
                {
                    source.SetResult(connector.GetUsersSync());
                });

            return await task;

        }

public async Task<List<User>> GetUsers()
        {
            List<User> users = new List<User>();
            using (var connection = new SqlConnection(ConnectionString))
            {
                using (Command = connection.CreateCommand())
                {
                    await connection.OpenAsync();
                    Command.CommandType = System.Data.CommandType.Text;
                    Command.CommandText = "SELECT UserId, FirstName, LastName FROM [dbo].[User]";
                    using (Reader = await Command.ExecuteReaderAsync())
                    {
                        while (await Reader.ReadAsync())
                        {
                            User user = new User();
                            user.Id = Reader[0] as int? ?? default(int?);
                            user.FirstName = Reader[1] as string;
                            user.LastName = Reader[2] as string;

                            users.Add(user);
                        }
                    }
                }
            }
            return users;
        }