Added sample scripts for use cases

+ Fixed failing spec for bulk copy metadata

Author: Zeqi Cui

samples/scripts/BulkCopySample.scala

@@ -0,0 +1,43 @@
+// Import libraries
+import com.microsoft.azure.sqldb.spark.bulkcopy.BulkCopyMetadata
+import com.microsoft.azure.sqldb.spark.config.Config
+import com.microsoft.azure.sqldb.spark.connect._
+
+val url = "[Enter your url here]"
+val databaseName = "[Enter your database name here]"
+val dbTable = "[Enter your database table here]"
+
+val user = "[Enter your username here]"
+val password = "[Enter your password here]"
+
+// Acquire data to be written. 
+// df could be aquired in any way.
+val localTable = "[Enter your local persisted table here]"
+val df = spark.sql(s"SELECT * FROM $localTable")
+
+val writeConfig = Config(Map(
+  "url"               -> url,
+  "databaseName"      -> databaseName,
+  "dbTable"           -> dbTable,
+  "user"              -> user, 
+  "password"          -> password,
+  "connectTimeout"    -> "5",
+  "bulkCopyBatchSize" -> "100000",
+  "bulkCopyTableLock" -> "true",
+  "bulkCopyTimeout"   -> "600"
+))
+
+df.bulkCopyToSqlDB(writeConfig)
+
+/**
+For better performance, specify the column metadata of the table
+
+var bulkCopyMetadata = new BulkCopyMetadata
+bulkCopyMetadata.addColumnMetadata(1, "Title", java.sql.Types.NVARCHAR, 128, 0)
+bulkCopyMetadata.addColumnMetadata(2, "FirstName", java.sql.Types.NVARCHAR, 128, 0)
+bulkCopyMetadata.addColumnMetadata(3, "MiddleName", java.sql.Types.NVARCHAR, 128, 0)
+bulkCopyMetadata.addColumnMetadata(4, "LastName", java.sql.Types.NVARCHAR, 128, 0)
+..........
+
+df.bulkCopyToSqlDB(writeConfig, bulkCopyMetadata)
+**/

samples/scripts/ReadSample.scala

@@ -0,0 +1,40 @@
+// Import libraries
+import com.microsoft.azure.sqldb.spark.bulkcopy.BulkCopyMetadata
+import com.microsoft.azure.sqldb.spark.config.Config
+import com.microsoft.azure.sqldb.spark.connect._
+
+val url = "[Enter your url here]"
+val databaseName = "[Enter your database name here]"
+val dbTable = "[Enter your database table here]"
+
+val user = "[Enter your username here]"
+val password = "[Enter your password here]"
+
+// READ FROM CONFIG
+val readConfig = Config(Map(
+  "url"            -> url,
+  "databaseName"   -> databaseName,
+  "user"           -> user,
+  "password"       -> password,
+  "connectTimeout" -> "5",
+  "queryTimeout"   -> "5",
+  "dbTable"        -> dbTable
+))
+
+val df = sqlContext.read.sqlDB(readConfig)
+println("Total rows: " + df.count)
+df.show()
+
+// TRADITIONAL SYNTAX
+import java.util.Properties
+
+val properties = new Properties()
+properties.put("databaseName", databaseName)
+properties.put("user", user)
+properties.put("password", password)
+properties.put("connectTimeout", "5")
+properties.put("queryTimeout", "5")
+
+val df = sqlContext.read.sqlDB(url, dbTable, properties)
+println("Total rows: " + df.count)
+df.show()

samples/scripts/WriteSample.scala

@@ -0,0 +1,44 @@
+// Import libraries
+import com.microsoft.azure.sqldb.spark.config.Config
+import com.microsoft.azure.sqldb.spark.connect._
+
+val url = "[Enter your url here]"
+val databaseName = "[Enter your database name here]"
+val dbTable = "[Enter your database table here]"
+
+val user = "[Enter your username here]"
+val password = "[Enter your password here]"
+
+// Acquire data to be written. 
+// df could be aquired in any way.
+val localTable = "[Enter your local persisted table here]"
+val df = spark.sql(s"SELECT * FROM $localTable")
+
+// WRITE FROM CONFIG
+val writeConfig = Config(Map(
+  "url"            -> url,
+  "databaseName"   -> databaseName,
+  "dbTable"        -> dbTable,
+  "user"           -> user, 
+  "password"       -> password,
+  "connectTimeout" -> "5",
+  "queryTimeout"   -> "5"
+))
+
+df.write.mode(SaveMode.Append).sqlDB(writeConfig)
+
+/** TRADITIONAL SYNTAX
+
+import java.util.Properties
+
+val properties = new Properties()
+
+properties.put("databaseName", databaseName)
+properties.put("user", user)
+properties.put("password", password)
+properties.put("connectTimeout", "5")
+properties.put("queryTimeout", "5")
+
+df.write.mode(SaveMode.Append).sqlDB(url, dbTable, properties)
+
+**/

src/test/java/com/microsoft/azure/sqldb/spark/bulkcopy/BulkCopyMetadataSpec.java

@@ -47,16 +47,15 @@ public void constructorTest(){
     @Test
     public void addColumnMetadataTest() {
         String columnName = "testColumn";
-        int column = 1;
         int jdbcType = Types.DOUBLE;
         int precision = 15;
         int scale = 5;
         DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss");
 
-        bulkCopyMetadata.addColumnMetadata(column, columnName, jdbcType, precision, scale);
+        bulkCopyMetadata.addColumnMetadata(1, columnName, jdbcType, precision, scale);
         assertEquals(1, bulkCopyMetadata.getMetadata().size());
 
-        bulkCopyMetadata.addColumnMetadata(column, columnName, jdbcType, precision, scale, dateTimeFormatter);
+        bulkCopyMetadata.addColumnMetadata(2, columnName, jdbcType, precision, scale, dateTimeFormatter);
         assertEquals(2, bulkCopyMetadata.getMetadata().size());
     }
 }