Initial changes

Author: tkyc

src/main/java/com/microsoft/sqlserver/jdbc/Parameter.java

@@ -415,18 +415,22 @@ void setValue(JDBCType jdbcType, Object value, JavaType javaType, StreamSetterAr
         // the value with the appropriate corresponding Unicode type.
         // JavaType.OBJECT == javaType when calling setNull()
         if (con.sendStringParametersAsUnicode() && (JavaType.STRING == javaType || JavaType.READER == javaType
-                || JavaType.CLOB == javaType || JavaType.OBJECT == javaType)) {
+                || JavaType.CLOB == javaType || JavaType.OBJECT == javaType) && jdbcType != JDBCType.VARCHAR) {
             jdbcType = getSSPAUJDBCType(jdbcType);
         }
 
         DTV newDTV = new DTV();
         newDTV.setValue(con.getDatabaseCollation(), jdbcType, value, javaType, streamSetterArgs, calendar, scale, con,
                 forceEncrypt);
 
-        if (!con.sendStringParametersAsUnicode()) {
+        if (!con.sendStringParametersAsUnicode() || (con.sendStringParametersAsUnicode() && jdbcType == JDBCType.VARCHAR)) {
             newDTV.sendStringParametersAsUnicode = false;
         }
 
+        if (con.sendStringParametersAsUnicode() && jdbcType == JDBCType.VARCHAR && (!con.getDatabaseCollation().isUtf8Encoding() || con.getServerMajorVersion() < 15)) {
+            throw new SQLServerException(SQLServerException.getErrString("R_possibleColumnDataCorruption"), null);
+        }
+
         inputDTV = setterDTV = newDTV;
     }
 

src/main/java/com/microsoft/sqlserver/jdbc/SQLCollation.java

@@ -56,6 +56,10 @@ final boolean hasAsciiCompatibleSBCS() {
         return encoding.hasAsciiCompatibleSBCS();
     }
 
+    boolean isUtf8Encoding() {
+        return encoding.equals(Encoding.UTF8);
+    }
+
     static final int tdsLength() {
         return TDS_LENGTH;
     } // Length of collation in TDS (in bytes)

src/main/java/com/microsoft/sqlserver/jdbc/SQLServerResource.java

@@ -165,6 +165,7 @@ protected Object[][] getContents() {
         {"R_invalidDatetimeType", "The datetimeType connection property {0} is not valid."},
         {"R_dataAlreadyAccessed", "The data has been accessed and is not available for this column or parameter."},
         {"R_outParamsNotPermittedinBatch", "The OUT and INOUT parameters are not permitted in a batch."},
+        {"R_possibleColumnDataCorruption", "Attempted to insert encrypted unicode data into non-unicode column. Data corruption may occur."},
         {"R_colNotMatchTable", "Number of provided columns {0} does not match the table definition {1}."},
         {"R_invalidSQL", "Invalid SQL query {0}."},
         {"R_multipleQueriesNotAllowed", "Multiple queries are not allowed."},