fix: always primary

.github/DEPEND.md

@@ -13,7 +13,7 @@ repositories {
 
 dependencies {
     // other depends
-    implementation 'works.naifu:wonsi:1.0.0'
+    implementation 'io.github.dynomake:wonsi:1.0.2'
 }
 ```
 
@@ -33,8 +33,8 @@ Depend:
 ```xml
 
 <dependency>
-    <groupId>works.naifu</groupId>
+    <groupId>io.github.dynomake</groupId>
     <artifactId>wonsi</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.2</version>
 </dependency>
 ```

build.gradle

@@ -3,8 +3,8 @@ plugins {
     id 'maven-publish'
 }
 
-group 'works.naifu'
-version '1.0.0'
+group 'io.github.dynomake'
+version '1.0.2'
 tasks.withType(JavaCompile) {
     options.encoding = 'UTF-8'
 }
@@ -39,6 +39,15 @@ publishing {
     publications {
         gpr(MavenPublication) {
             from(components.java)
+
+            pom {
+                licenses {
+                    license {
+                        name = 'MIT License'
+                        url = 'https://github.com/dynomake/wonsi/blob/master/LICENSE'
+                    }
+                }
+            }
         }
     }
 }

src/main/java/net/wonsi/api/result/ExecutedReturningAction.java

@@ -1,10 +1,11 @@
 package net.wonsi.api.result;
 
 import java.util.Collection;
+import java.util.Optional;
 
 public interface ExecutedReturningAction<T> {
 
     Collection<T> getAll();
-    T findFirst();
+    Optional<T> findFirst();
     boolean isEmpty();
 }

src/main/java/net/wonsi/column/ColumnUtil.java

@@ -7,6 +7,7 @@
 import java.math.BigDecimal;
 import java.sql.Date;
 import java.sql.Timestamp;
+import java.util.Collection;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -36,9 +37,12 @@ public class ColumnUtil {
         TYPE_MAP.put(float.class, new FloatType());
         TYPE_MAP.put(double.class, new FloatType());
         TYPE_MAP.put(BigDecimal.class, new FloatType());
+        TYPE_MAP.put(Collection.class, new JsonType());
     }
 
     public ColumnType get(@NonNull Class<?> javaType) {
+        if (javaType.isAssignableFrom(Collection.class)) return new JsonType();
+
         return TYPE_MAP.getOrDefault(javaType, new VarcharType());
     }
 }

src/main/java/net/wonsi/column/type/JsonType.java

@@ -0,0 +1,9 @@
+package net.wonsi.column.type;
+
+public class JsonType implements ColumnType {
+
+    @Override
+    public String convertToString(int length) {
+        return "json";
+    }
+}

src/main/java/net/wonsi/proxy/result/RealExecutedReturningAction.java

@@ -6,6 +6,7 @@
 import java.sql.ResultSet;
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Optional;
 import java.util.function.Function;
 
 public class RealExecutedReturningAction<T> implements ExecutedReturningAction<T> {
@@ -33,8 +34,8 @@ public Collection<T> getAll() {
     }
 
     @Override
-    public T findFirst() {
-        return response.stream().findFirst().orElse(null);
+    public Optional<T> findFirst() {
+        return response.stream().findFirst();
     }
 
     @Override

src/main/java/net/wonsi/proxy/table/RealWonsiTable.java

@@ -76,7 +76,7 @@ public void createIfNotExits(Class<T> tclass) {
 
         for (Field field : tclass.getDeclaredFields()) {
             WonsiColumn column = field.getAnnotation(WonsiColumn.class);
-            arguments.add(column.name() + ' ' + ColumnUtil.get(field.getType()).convertToString(column.length()) + field.getAnnotation(WonsiPrimary.class) != null ? " PRIMARY KEY" : "");
+            arguments.add(column.name() + ' ' + ColumnUtil.get(field.getType()).convertToString(column.length()) + (field.getAnnotation(WonsiPrimary.class) != null ? " PRIMARY KEY" : ""));
         }
 
         StringBuilder query = new StringBuilder("CREATE TABLE IF NOT EXISTS `");

src/test/java/net/wonsi/test/mysql/MySqlUtil.java

@@ -1,29 +1,19 @@
 package net.wonsi.test.mysql;
 
 import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
+import lombok.SneakyThrows;
 import lombok.experimental.UtilityClass;
 
 import java.sql.Connection;
+import java.sql.DriverManager;
 import java.sql.SQLException;
 
 @UtilityClass
 public class MySqlUtil {
 
+    @SneakyThrows
     public Connection create() {
-        MysqlDataSource dataSource = new MysqlDataSource();
-        dataSource.setServerName("localhost");
-        dataSource.setPort(3306);
-        dataSource.setUser("root");
-        dataSource.setPassword("nope");
-        dataSource.setDatabaseName("wonsitesting");
-
-        dataSource.setEncoding("UTF-8");
-        dataSource.setAutoReconnect(true);
-        dataSource.setUseSSL(true);
-        try {
-            return dataSource.getConnection();
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
+        var url = "jdbc:h2:mem:";
+        return DriverManager.getConnection(url);
     }
 }

src/test/java/net/wonsi/test/repo/UserRepo.java

@@ -26,7 +26,7 @@ public User getByLogin(String login) {
                 .where(Condition.is("login", login))
                 .limit(1)
                 .sync()
-                .findFirst();
+                .findFirst().get();
     }
 
     public Collection<User> getAll() {