202103240936

pom.xml

@@ -96,6 +96,13 @@
 			<version>1.18.16</version>
 			<optional>true</optional>
 		</dependency>
+		<!-- https://mvnrepository.com/artifact/com.microsoft.sqlserver/mssql-jdbc -->
+		<dependency>
+			<groupId>com.microsoft.sqlserver</groupId>
+			<artifactId>mssql-jdbc</artifactId>
+			<version>9.2.1.jre8</version>
+		</dependency>
+
 
 	</dependencies>
 

src/main/java/com/moze/rms/dao/AssertDAO.java

@@ -35,14 +35,20 @@ public interface AssertDAO extends SqlObject {
     }
 
     @RegisterBeanMapper(MappingCol.class)
-    @SqlQuery("select * from mapping.mapping_col order by index;")
+    @SqlQuery("select * from mapping.mapping_col order by [index];")
     List<MappingCol> findAllCols();
 
 
     //新增類別
     default void insertAssertGroup(Map<String, Object> data) {
         Handle handle = this.getHandle();
-        String sql = "CREATE TABLE " + data.get("assertGroupTablename") + "()";
+        String sql = "create table " + data.get("assertGroupTablename") +
+                "(" +
+                "    id         int not null" +
+                "        constraint " + data.get("assertGroupTablename") + "_pk" +
+                "            primary key nonclustered," +
+                "    type       nvarchar(256)," +
+                ")";
         handle.createUpdate(sql).execute();
     }
 
@@ -94,7 +100,7 @@ public interface AssertDAO extends SqlObject {
 
     }
 
-    @SqlQuery("select item from mapping.\"selectItem\" where tablename = ? and colname = ? order by index;")
+    @SqlQuery("select item from mapping.\"selectItem\" where tablename = ? and colname = ? order by [index];")
     @RegisterBeanMapper(SelectItemDTO.class)
     List<String> getSelectItemsByCol(String tablename, String colname);
 
@@ -117,7 +123,7 @@ public interface AssertDAO extends SqlObject {
             String name = fields[i].getName();
             String type = fields[i].getGenericType().toString();
             if (type.equals("class java.lang.String") && i < fields.length - 1) {
-                cols += name;
+                cols += "[" + name + "]";
                 if (i < fields.length - 1) {
                     cols += ",";
                 }
@@ -174,7 +180,7 @@ public interface AssertDAO extends SqlObject {
                 String name2 = name.substring(0, 1).toUpperCase() + name.substring(1);
                 Method method = m.getClass().getMethod("get" + name2);
                 String value = (String) method.invoke(m);
-                sql += " " + name + " = '" + value + "',";
+                sql += " [" + name + "] = '" + value + "',";
             }
         }
         if (sql.endsWith(",")) {
@@ -191,7 +197,7 @@ public interface AssertDAO extends SqlObject {
         if (m.getInsertSelectItems() != null) {
             for (int i = 1; i <= m.getInsertSelectItems().size(); i++) {
                 String sql = "update mapping.\"selectItem\" set ";
-                sql += "index = '" + i + "'";
+                sql += "[index] = '" + i + "'";
                 sql += "where tablename = '" + m.getTablename() + "'";
                 sql += "and colname = '" + m.getColname() + "'";
 
@@ -222,12 +228,12 @@ public interface AssertDAO extends SqlObject {
         handle.createUpdate(sql).execute();
     }
 
-    @SqlUpdate("update mapping.mapping_col set index = index + 1 where index < ?::numeric and index >= ?::numeric where tablename = ?")
+    @SqlUpdate("update mapping.mapping_col set [index] = [index] + 1 where [index] < CAST(? as int) and [index] >= CAST(? as int) and tablename = ?")
     void sortCol1(String oldIndex ,String index, String tablename);
 
-    @SqlUpdate("update mapping.mapping_col set index = index - 1 where index > ?::numeric and index <= ?::numeric  where tablename = ?")
+    @SqlUpdate("update mapping.mapping_col set [index] = [index] - 1 where [index] > CAST(? as int) and [index] <= CAST(? as int) and tablename = ?")
     void sortCol2(String oldIndex ,String index, String tablename);
 
-    @SqlUpdate("select index from mapping.mapping_col where tablename = ? order by index desc limit 1;")
+    @SqlUpdate("select [index] from mapping.mapping_col where tablename = ? order by [index] desc limit 1;")
     Integer getLastIndex(String tablename);
 }

src/main/java/com/moze/rms/dao/InventoryDAO.java

@@ -29,9 +29,9 @@ public interface InventoryDAO extends SqlObject {
         for (Map.Entry<String, Object> entry : data.entrySet()) {
             if (!entry.getKey().equals("id") && !entry.getKey().equals("tablename"))
                 if (entry.getValue() != null) {
-                    sql += entry.getKey() + " = '" + entry.getValue() + "',";
+                    sql += "[" + entry.getKey() + "] = '" + entry.getValue() + "',";
                 } else {
-                    sql += entry.getKey() + " = " + entry.getValue() + ",";
+                    sql += "[" + entry.getKey() + "] = " + entry.getValue() + ",";
                 }
         }
         sql = sql.substring(0, sql.length() - 1);
@@ -39,7 +39,7 @@ public interface InventoryDAO extends SqlObject {
         handle.createUpdate(sql).execute();
     }
 
-    @SqlQuery("select colname, item from mapping.\"selectItem\" where tablename = ? order by index;")
+    @SqlQuery("select colname, item from mapping.\"selectItem\" where tablename = ? order by [index];")
     @RegisterBeanMapper(SelectItemDTO.class)
     List<SelectItemDTO> getSelectItemByTable(String tablename);
 
@@ -60,7 +60,7 @@ public interface InventoryDAO extends SqlObject {
             Object value = next.getValue();
             System.out.println(key);
             if (key != "tablename" && key != "id") {
-                cols += key + ", ";
+                cols += "[" + key + "], ";
                 values += "'" + value + "', ";
             }
         }

src/main/java/com/moze/rms/dao/MappingColDAO.java

@@ -11,6 +11,6 @@ import java.util.List;
 public interface MappingColDAO {
 
 
-    @SqlQuery("select * from mapping.mapping_col where tablename = ? order by index;")
+    @SqlQuery("select * from mapping.mapping_col where tablename = ? order by [index];")
     List<MappingCol> findByTable(String tablename);
 }

src/main/resources/application-dev.properties

@@ -1,8 +1,8 @@
 server.servlet.context-path=/
 
-spring.datasource.url=jdbc:postgresql://172.105.222.191:54132/rms
-spring.datasource.username=moze
-spring.datasource.password=moze794064,!
+spring.datasource.url=jdbc:sqlserver://172.105.222.191:1433;databaseName=rms;
+spring.datasource.username=sa
+spring.datasource.password=Moze794064,!
 server.port=8081