diff --git a/.travis.yml b/.travis.yml
index f04dabe6..07becfb2 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -4,3 +4,8 @@ node_js:
   - "4.2"
   - "0.10"
   - "0.11"
+
+matrix:
+  allow_failures:
+    - node_js: "0.10"
+    - node_js: "0.11"
\ No newline at end of file
diff --git a/lib/dialect/mssql.js b/lib/dialect/mssql.js
index 488f7fa2..6e71f2e1 100644
--- a/lib/dialect/mssql.js
+++ b/lib/dialect/mssql.js
@@ -48,6 +48,10 @@ Mssql.prototype.visitBinary = function(binary) {
     return [text];
   }
 
+  if(binary.operator === '||'){
+    return ['(' + this.visit(binary.left) + ' + ' + this.visit(binary.right) + ')'];
+  }
+
   if (!isRightSideArray(binary)){
     return Mssql.super_.prototype.visitBinary.call(this, binary);
   }
@@ -274,6 +278,16 @@ Mssql.prototype.visitFunctionCall = function(functionCall) {
   return [txt];
 };
 
+Mssql.prototype.visitJoin = function(join) {
+  if (join.subType !== 'LEFT LATERAL') return Mssql.super_.prototype.visitJoin.call(this, join);
+  var result = [];
+  this._visitingJoin = true;
+  result = result.concat(this.visit(join.from));
+  result = result.concat('OUTER APPLY');
+  result = result.concat(this.visit(join.to));
+  return result;
+};
+
 Mssql.prototype.visitOrderBy = function(orderBy) {
   var result=Mssql.super_.prototype.visitOrderBy.call(this, orderBy);
   var offsetNode=orderBy.msSQLOffsetNode;
diff --git a/lib/dialect/oracle.js b/lib/dialect/oracle.js
index 38267339..a55e7aca 100644
--- a/lib/dialect/oracle.js
+++ b/lib/dialect/oracle.js
@@ -278,6 +278,11 @@ Oracle.prototype.visitCase = function(caseExp) {
   return Mssql.prototype.visitCase.call(this, caseExp);
 };
 
+// Using same JOIN implementation as MSSQL
+Oracle.prototype.visitJoin = function(joinExp) {
+  return Mssql.prototype.visitJoin.call(this, joinExp);
+};
+
 Oracle.prototype.visitOnConflict = function(onConflict) {
   throw new Error('Oracle does not allow onConflict clause.');
 };
diff --git a/lib/dialect/postgres.js b/lib/dialect/postgres.js
index 2816c901..9b81af25 100644
--- a/lib/dialect/postgres.js
+++ b/lib/dialect/postgres.js
@@ -1022,6 +1022,7 @@ Postgres.prototype.visitForShare = function() {
 };
 
 Postgres.prototype.visitJoin = function(join) {
+  if (join.subType === 'LEFT LATERAL') return this.visitLeftJoinLateral(join);
   var result = [];
   this._visitingJoin = true;
   result = result.concat(this.visit(join.from));
@@ -1032,6 +1033,16 @@ Postgres.prototype.visitJoin = function(join) {
   return result;
 };
 
+Postgres.prototype.visitLeftJoinLateral = function(join) {
+  var result = [];
+  this._visitingJoin = true;
+  result = result.concat(this.visit(join.from));
+  result = result.concat('LEFT JOIN LATERAL');
+  result = result.concat(this.visit(join.to));
+  result = result.concat('ON true');
+  return result;
+};
+
 Postgres.prototype.visitLiteral = function(node) {
   var txt = [node.literal];
   if(node.alias) {
diff --git a/lib/index.js b/lib/index.js
index f6cf39e6..f26ad827 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -1,11 +1,12 @@
 'use strict';
 
 var _            = require('lodash');
-var Column 		 = require("./column");
+var Column       = require("./column");
 var FunctionCall = require('./node/functionCall');
 var ArrayCall    = require('./node/arrayCall');
 var functions    = require('./functions');
 var getDialect   = require('./dialect');
+var JoinNode     = require('./node/join');
 var Query        = require('./node/query');
 var sliced       = require('sliced');
 var Table        = require('./table');
@@ -52,6 +53,18 @@ Sql.prototype.select = function() {
   return query;
 };
 
+// Returns a subQuery clause
+Sql.prototype.subQuery = function(alias) {
+  // create the query and pass it off
+  var query = new Query(this);
+  query.type = 'SUBQUERY';
+  query.alias = alias;
+  query.join = function(other) {
+    return new JoinNode('INNER', this.toNode(), other.toNode(), other);
+  };
+  return query;
+};
+
 // Returns an interval clause
 Sql.prototype.interval = function() {
   var interval = new Interval(sliced(arguments));
diff --git a/lib/node/join.js b/lib/node/join.js
index bbc1f93a..f569997e 100644
--- a/lib/node/join.js
+++ b/lib/node/join.js
@@ -19,5 +19,8 @@ var JoinNode = module.exports = Node.define({
   },
   leftJoin: function(other) {
     return new JoinNode('LEFT', this, other);
+  },
+  leftJoinLateral: function(other) {
+    return new JoinNode('LEFT LATERAL', this, other);
   }
 });
diff --git a/lib/table.js b/lib/table.js
index 3fae2710..1408542b 100644
--- a/lib/table.js
+++ b/lib/table.js
@@ -237,6 +237,10 @@ Table.prototype.leftJoin = function(other) {
   return new JoinNode('LEFT', this.toNode(), other.toNode());
 };
 
+Table.prototype.leftJoinLateral = function(other) {
+  return new JoinNode('LEFT LATERAL', this.toNode(), other.toNode());
+};
+
 // auto-join tables based on column intropsection
 Table.prototype.joinTo = function(other) {
   return Joiner.leftJoin(this, other);
diff --git a/lib/types.d.ts b/lib/types.d.ts
index 84fb7ab3..a7011f99 100644
--- a/lib/types.d.ts
+++ b/lib/types.d.ts
@@ -37,7 +37,7 @@ declare module "sql" {
 	interface TableDefinition<Name extends string, Row> {
 		name: Name;
 		schema: string;
-		columns: {[CName in keyof Row]: ColumnDefinition<CName, Row[CName]>};
+		columns: {[CName in ((keyof Row) & string)]: ColumnDefinition<CName, Row[CName]>};
 		dialect?: SQLDialects;
 		isTemporary?: boolean;
 		foreignKeys?: {
diff --git a/test/dialects/join-tests.js b/test/dialects/join-tests.js
index abebdb01..2e0c6882 100644
--- a/test/dialects/join-tests.js
+++ b/test/dialects/join-tests.js
@@ -174,3 +174,57 @@ Harness.test({
   },
   params: []
 });
+
+Harness.test({
+  query: user.select().from(user.leftJoinLateral(post.subQuery().select(post.userId))),
+  pg: {
+    text  : 'SELECT "user".* FROM "user" LEFT JOIN LATERAL (SELECT "post"."userId" FROM "post") ON true',
+    string: 'SELECT "user".* FROM "user" LEFT JOIN LATERAL (SELECT "post"."userId" FROM "post") ON true'
+  },
+  mssql: {
+    text  : 'SELECT [user].* FROM [user] OUTER APPLY (SELECT [post].[userId] FROM [post])',
+    string: 'SELECT [user].* FROM [user] OUTER APPLY (SELECT [post].[userId] FROM [post])'
+  },
+  oracle: {
+    text  : 'SELECT "user".* FROM "user" OUTER APPLY (SELECT "post"."userId" FROM "post")',
+    string: 'SELECT "user".* FROM "user" OUTER APPLY (SELECT "post"."userId" FROM "post")'
+  },
+  params: []
+});
+
+Harness.test({
+  query: user.select().from(user.leftJoinLateral(post.subQuery().select(post.userId).where(user.id.equals(post.userId)))),
+  pg: {
+    text  : 'SELECT "user".* FROM "user" LEFT JOIN LATERAL (SELECT "post"."userId" FROM "post" WHERE ("user"."id" = "post"."userId")) ON true',
+    string: 'SELECT "user".* FROM "user" LEFT JOIN LATERAL (SELECT "post"."userId" FROM "post" WHERE ("user"."id" = "post"."userId")) ON true'
+  },
+  mssql: {
+    text  : 'SELECT [user].* FROM [user] OUTER APPLY (SELECT [post].[userId] FROM [post] WHERE ([user].[id] = [post].[userId]))',
+    string: 'SELECT [user].* FROM [user] OUTER APPLY (SELECT [post].[userId] FROM [post] WHERE ([user].[id] = [post].[userId]))'
+  },
+  oracle: {
+    text  : 'SELECT "user".* FROM "user" OUTER APPLY (SELECT "post"."userId" FROM "post" WHERE ("user"."id" = "post"."userId"))',
+    string: 'SELECT "user".* FROM "user" OUTER APPLY (SELECT "post"."userId" FROM "post" WHERE ("user"."id" = "post"."userId"))'
+  },
+  params: []
+});
+
+Harness.test({
+  query: user.select().from(user
+  	.leftJoinLateral(post.subQuery().select(post.userId))
+  	.leftJoinLateral(comment.subQuery().select(comment.postId))),
+  pg: {
+    text  : 'SELECT "user".* FROM "user" LEFT JOIN LATERAL (SELECT "post"."userId" FROM "post") ON true LEFT JOIN LATERAL (SELECT "comment"."postId" FROM "comment") ON true',
+    string: 'SELECT "user".* FROM "user" LEFT JOIN LATERAL (SELECT "post"."userId" FROM "post") ON true LEFT JOIN LATERAL (SELECT "comment"."postId" FROM "comment") ON true'
+  },
+  mssql: {
+    text  : 'SELECT [user].* FROM [user] OUTER APPLY (SELECT [post].[userId] FROM [post]) OUTER APPLY (SELECT [comment].[postId] FROM [comment])',
+    string: 'SELECT [user].* FROM [user] OUTER APPLY (SELECT [post].[userId] FROM [post]) OUTER APPLY (SELECT [comment].[postId] FROM [comment])'
+  },
+  oracle: {
+    text  : 'SELECT "user".* FROM "user" OUTER APPLY (SELECT "post"."userId" FROM "post") OUTER APPLY (SELECT "comment"."postId" FROM "comment")',
+    string: 'SELECT "user".* FROM "user" OUTER APPLY (SELECT "post"."userId" FROM "post") OUTER APPLY (SELECT "comment"."postId" FROM "comment")'
+  },
+  params: []
+});
+
diff --git a/test/dialects/subquery-tests.js b/test/dialects/subquery-tests.js
index fe5b2aad..05d76f1f 100644
--- a/test/dialects/subquery-tests.js
+++ b/test/dialects/subquery-tests.js
@@ -219,3 +219,55 @@ Harness.test({
   params: []
 });
 
+// Top-level subQuery
+Harness.test({
+  query: Sql.subQuery().select(user.id).from(user),
+  pg: {
+    text  : '(SELECT "user"."id" FROM "user")',
+    string: '(SELECT "user"."id" FROM "user")'
+  },
+  sqlite: {
+    text  : '(SELECT "user"."id" FROM "user")',
+    string: '(SELECT "user"."id" FROM "user")'
+  },
+  mysql: {
+    text  : '(SELECT `user`.`id` FROM `user`)',
+    string: '(SELECT `user`.`id` FROM `user`)'
+  },
+  mssql: {
+    text  : '(SELECT [user].[id] FROM [user])',
+    string: '(SELECT [user].[id] FROM [user])'
+  },
+  oracle: {
+    text  : '(SELECT "user"."id" FROM "user")',
+    string: '(SELECT "user"."id" FROM "user")'
+  },
+  params: []
+});
+
+// Top-level subQuery with alias
+Harness.test({
+  query: Sql.subQuery("x").select(user.id).from(user),
+  pg: {
+    text  : '(SELECT "user"."id" FROM "user") "x"',
+    string: '(SELECT "user"."id" FROM "user") "x"'
+  },
+  sqlite: {
+    text  : '(SELECT "user"."id" FROM "user") "x"',
+    string: '(SELECT "user"."id" FROM "user") "x"'
+  },
+  mysql: {
+    text  : '(SELECT `user`.`id` FROM `user`) `x`',
+    string: '(SELECT `user`.`id` FROM `user`) `x`'
+  },
+  mssql: {
+    text  : '(SELECT [user].[id] FROM [user]) [x]',
+    string: '(SELECT [user].[id] FROM [user]) [x]'
+  },
+  oracle: {
+    text  : '(SELECT "user"."id" FROM "user") "x"',
+    string: '(SELECT "user"."id" FROM "user") "x"'
+  },
+  params: []
+});
+
diff --git a/test/dialects/value-expression-tests.js b/test/dialects/value-expression-tests.js
index 5eaae5ae..d5c7fcd4 100644
--- a/test/dialects/value-expression-tests.js
+++ b/test/dialects/value-expression-tests.js
@@ -114,20 +114,46 @@ Harness.test({
   query: post.select(post.id).where(post.content.equals(new Buffer('test'))),
   pg: {
     text  : 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = $1)',
-    string: 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = \'\\x74657374\')',
+    string: 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = \'\\x74657374\')'
   },
   sqlite: {
     text  : 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = $1)',
-    string: 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = x\'74657374\')',
+    string: 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = x\'74657374\')'
   },
   mysql: {
     text  : 'SELECT `post`.`id` FROM `post` WHERE (`post`.`content` = ?)',
-    string: 'SELECT `post`.`id` FROM `post` WHERE (`post`.`content` = x\'74657374\')',
+    string: 'SELECT `post`.`id` FROM `post` WHERE (`post`.`content` = x\'74657374\')'
   },
   oracle: {
     text  : 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = :1)',
-    string: 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = utl_raw.cast_to_varchar2(hextoraw(\'74657374\')))',
+    string: 'SELECT "post"."id" FROM "post" WHERE ("post"."content" = utl_raw.cast_to_varchar2(hextoraw(\'74657374\')))'
   },
   params: [new Buffer('test')]
 });
 
+// concat tests
+Harness.test({
+  query: post.select(post.content.concat(post.tags)),
+  pg: {
+    text  : 'SELECT ("post"."content" || "post"."tags") FROM "post"',
+    string: 'SELECT ("post"."content" || "post"."tags") FROM "post"'
+  },
+  sqlite: {
+    text  : 'SELECT ("post"."content" || "post"."tags") FROM "post"',
+    string: 'SELECT ("post"."content" || "post"."tags") FROM "post"'
+  },
+  mysql: {
+    text  : 'SELECT (`post`.`content` || `post`.`tags`) FROM `post`',
+    string: 'SELECT (`post`.`content` || `post`.`tags`) FROM `post`'
+  },
+  mssql: {
+    text  : 'SELECT ([post].[content] + [post].[tags]) FROM [post]',
+    string: 'SELECT ([post].[content] + [post].[tags]) FROM [post]'
+  },
+  oracle: {
+    text  : 'SELECT ("post"."content" || "post"."tags") FROM "post"',
+    string: 'SELECT ("post"."content" || "post"."tags") FROM "post"'
+  },
+  params: []
+});
+