package com.sqltest.db;

import com.sqltest.base.BaseTest;

import com.sqltest.dto.UserInfoDto;

import com.sqltest.model.UserInfo;

import io.github.cotide.dapper.Database;

import io.github.cotide.dapper.query.Sql;

import org.junit.Test;

import java.util.Date;

public class ExecuteTest extends BaseTest {

@Test

public void execute(){

try(Database db = getDatabase()){

db.beginTransaction();

final String insertSql =

"INSERT INTO user_info (user_Name,password,login,create_time) VALUES (?,?,?,?)";

int id = db.getSqlRun().execute(

insertSql,

"Execute Test",

"123456",

10086,

new Date()).asInt();

System.out.println("Object is :"+id);

assert (id>0):"insert is error";

final String updateSql =

"UPDATE user_info set user_Name = ? WHERE user_id = ?";

db.getSqlRun().execute(updateSql,"Execute Test2",id);

db.commit();

Sql sql = Sql.builder()

.select("user_id as id, user_Name as name")

.from(UserInfo.class).where("user_id = ?", id);

UserInfoDto resultDto = db.getSqlQuery().getDto(UserInfoDto.class,sql);

assert (resultDto!=null&&resultDto.getName().equals("Execute Test2")):"update get is error";

System.out.println(">>>>>>>>>> Result <<<<<<<<<<");

System.out.println(resultDto.getId());

System.out.println(resultDto.getName());

}

}

@Test

public void execute2(){

try(Database db = getDatabase()){

db.beginTransaction();

// Sql sql = Sql.builder().append(

// "INSERT INTO user_info (user_Name,password,login,create_time) VALUES (?,?,?,?);",

// "Execute Test1",

// "123456",

// 10086,

// new Date());

// sql.append("INSERT INTO user_info (user_Name,password,login,create_time) VALUES (?,?,?,?);",

// "Execute Test2",

// "123456",

// 10086,

// new Date());

String sql =

"INSERT INTO user_info (user_Name,password,login,create_time) VALUES ('ATest1','123456',10086,'2018-10-11 10:20:01');";

sql = sql+ "INSERT INTO user_info (user_Name,password,login,create_time) VALUES ('ATest1','123456',10086,'2018-10-11 10:20:01');";

System.out.println(sql);

db.getSqlRun().execute(sql);

db.commit();

}

}

}