read/write buffers

Author: refractalize

index.js

@@ -13,7 +13,7 @@ var rowBase = function() {
   function fieldsForObject(obj) {
     return Object.keys(obj).filter(function (key) {
       var value = obj[key];
-      return value instanceof Date || value !== null && value !== undefined && !(value instanceof Object);
+      return value instanceof Date || value instanceof Buffer || value !== null && value !== undefined && !(value instanceof Object);
     });
   }
 
@@ -23,7 +23,7 @@ var rowBase = function() {
         return false;
       } else {
         var value = obj[key];
-        return !(value instanceof Date) && value instanceof Object;
+        return !(value instanceof Date) && !(value instanceof Buffer) && value instanceof Object;
       }
     });
   }

test/describeDatabase.js

@@ -112,12 +112,30 @@ module.exports = function(name, config, database, otherTests) {
               return expect(database.clean(people)).to.eql([{
                 id: p.id,
                 name: "bob",
-                address_id: null
+                address_id: null,
+                photo: null
               }]);
             });
           });
         });
 
+        describe('binary', function () {
+          it('can store binary', function () {
+            var photo = new Buffer('♥︎');
+
+            var bob = person({
+              name: 'bob',
+              photo: photo
+            });
+
+            return bob.save().then(function () {
+              return db.query('select * from people').then(function (people) {
+                expect(people[0].photo.toString()).to.equal(photo.toString());
+              });
+            });
+          });
+        });
+
         it("can insert without connecting", function() {
           var db = sworm.db(config);
           var person = db.model({
@@ -133,7 +151,8 @@ module.exports = function(name, config, database, otherTests) {
               return expect(database.clean(people)).to.eql([{
                 id: p.id,
                 name: "bob",
-                address_id: null
+                address_id: null,
+                photo: null
               }]);
             });
           });
@@ -204,7 +223,8 @@ module.exports = function(name, config, database, otherTests) {
                 expect(database.clean(people)).to.eql([{
                   id: p.id,
                   name: "bob's name is 'matilda'",
-                  address_id: null
+                  address_id: null,
+                  photo: null
                 }]);
               });
             });
@@ -294,7 +314,8 @@ module.exports = function(name, config, database, otherTests) {
                 expect(database.clean(people)).to.eql([{
                     id: p.id,
                     name: "jane",
-                    address_id: null
+                    address_id: null,
+                    photo: null
                 }]);
               });
             });
@@ -671,7 +692,8 @@ module.exports = function(name, config, database, otherTests) {
                 expect(database.clean(people)).to.eql([{
                   id: bob.id,
                   name: 'bob',
-                  address_id: null
+                  address_id: null,
+                  photo: null
                 }]);
               });
             });

test/mssqlSpec.js

@@ -10,7 +10,7 @@ var database = {
     }
 
     return createTable("people",
-      'CREATE TABLE [dbo].[people]([id] [int] IDENTITY(1,1) NOT NULL, [name] [nvarchar](50) NOT NULL, [address_id] [int] NULL)'
+      'CREATE TABLE [dbo].[people]([id] [int] IDENTITY(1,1) NOT NULL, [name] [nvarchar](50) NOT NULL, [address_id] [int] NULL, photo varbinary(10) null)'
     ).then(function() {
       return createTable("people_addresses",
         'CREATE TABLE [dbo].[people_addresses]([address_id] [int] NOT NULL, [person_id] [int] NOT NULL, [rating] [int] NULL)'

test/mysqlSpec.js

@@ -24,7 +24,7 @@ var database = {
     }
 
     return createTable("people",
-      'create table if not exists people (id serial NOT NULL, name varchar(50) NOT NULL, address_id int NULL)'
+      'create table if not exists people (id serial NOT NULL, name varchar(50) NOT NULL, address_id int NULL, photo varbinary(10) null)'
     ).then(function() {
       return createTable("people_addresses",
         'create table if not exists people_addresses(address_id int NOT NULL, person_id int NOT NULL, rating int NULL)'

test/oracleSpec.js

@@ -51,7 +51,7 @@ if (!process.env.TRAVIS) {
       }
 
       return createTable("people", "id",
-        'create table people (id number primary key, name varchar2(50) NOT NULL, address_id number NULL)'
+        'create table people (id number primary key, name varchar2(50) NOT NULL, address_id number NULL, photo raw(10) null)'
       ).then(function() {
         return createTable("people_addresses", "address_id",
           'create table people_addresses(address_id int NOT NULL, person_id int NOT NULL, rating int NULL)',
@@ -191,7 +191,8 @@ if (!process.env.TRAVIS) {
             expect(rows.metaData).to.eql([
               {name: 'ID'},
               {name: 'NAME'},
-              {name: 'ADDRESS_ID'}
+              {name: 'ADDRESS_ID'},
+              {name: 'PHOTO'}
             ]);
           });
         });

test/postgresSpec.js

@@ -62,7 +62,7 @@ var database = {
     }
 
     return createTable("people",
-      'create table if not exists people (id serial NOT NULL, name varchar(50) NOT NULL, address_id int NULL)'
+      'create table if not exists people (id serial NOT NULL, name varchar(50) NOT NULL, address_id int NULL, photo bytea null)'
     ).then(function () {
       return createTable("people_addresses",
         'create table if not exists people_addresses(address_id int NOT NULL, person_id int NOT NULL, rating int NULL)'

test/sqliteSpec.js

@@ -10,7 +10,7 @@ var database = {
     }
 
     return createTable("people",
-      'create table if not exists people (id integer primary key, name varchar(50) NOT NULL, address_id integer NULL)'
+      'create table if not exists people (id integer primary key, name varchar(50) NOT NULL, address_id integer NULL, photo blob null)'
     ).then(function() {
       return createTable("people_addresses",
         'create table if not exists people_addresses(address_id integer NOT NULL, person_id integer NOT NULL, rating integer NULL)'