Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
mybatis-generator-plugin
Project overview
Project overview
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Administrator
mybatis-generator-plugin
Commits
a73bea39
Commit
a73bea39
authored
May 04, 2018
by
hewei
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
乐观锁插件测试整合增量插件用例
parent
50d1af8b
Changes
5
Show whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
425 additions
and
3 deletions
+425
-3
src/test/java/com/itfsw/mybatis/generator/plugins/OptimisticLockerPluginTest.java
...mybatis/generator/plugins/OptimisticLockerPluginTest.java
+292
-0
src/test/resources/scripts/OptimisticLockerPlugin/init.sql
src/test/resources/scripts/OptimisticLockerPlugin/init.sql
+1
-1
src/test/resources/scripts/OptimisticLockerPlugin/mybatis-generator-with-IncrementsPlugin.xml
...cLockerPlugin/mybatis-generator-with-IncrementsPlugin.xml
+69
-0
src/test/resources/scripts/OptimisticLockerPlugin/mybatis-generator-with-unfind-version-column.xml
...erPlugin/mybatis-generator-with-unfind-version-column.xml
+63
-0
src/test/resources/scripts/OptimisticLockerPlugin/mybatis-generator.xml
...rces/scripts/OptimisticLockerPlugin/mybatis-generator.xml
+0
-2
No files found.
src/test/java/com/itfsw/mybatis/generator/plugins/OptimisticLockerPluginTest.java
View file @
a73bea39
...
@@ -43,6 +43,17 @@ public class OptimisticLockerPluginTest {
...
@@ -43,6 +43,17 @@ public class OptimisticLockerPluginTest {
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
);
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
);
}
}
/**
* 测试配置异常
*/
@Test
public
void
testWarnings
()
throws
Exception
{
// 2. 没有找到配置的逻辑删除列
MyBatisGeneratorTool
tool
=
MyBatisGeneratorTool
.
create
(
"scripts/OptimisticLockerPlugin/mybatis-generator-with-unfind-version-column.xml"
);
tool
.
generate
();
Assert
.
assertEquals
(
tool
.
getWarnings
().
get
(
0
),
"itfsw(乐观锁插件):表tb配置的版本列(ttssss)没有找到!"
);
}
/**
/**
* 测试 deleteWithVersionByExample
* 测试 deleteWithVersionByExample
*/
*/
...
@@ -474,4 +485,285 @@ public class OptimisticLockerPluginTest {
...
@@ -474,4 +485,285 @@ public class OptimisticLockerPluginTest {
}
}
});
});
}
}
/**
* 测试整合IncrementsPlugin插件
*/
@Test
public
void
testWithIncrementsPlugin
()
throws
Exception
{
MyBatisGeneratorTool
tool
=
MyBatisGeneratorTool
.
create
(
"scripts/OptimisticLockerPlugin/mybatis-generator-with-IncrementsPlugin.xml"
);
// 测试updateWithVersionByExampleSelective
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbMapper"
)));
ObjectUtil
tbExample
=
new
ObjectUtil
(
loader
,
packagz
+
".TbExample"
);
ObjectUtil
criteria
=
new
ObjectUtil
(
tbExample
.
invoke
(
"createCriteria"
));
criteria
.
invoke
(
"andIdEqualTo"
,
1
l
);
ObjectUtil
tbBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder$Inc#INC"
);
tbBuilder
.
invoke
(
"id"
,
1L
);
tbBuilder
.
invoke
(
"incF1"
,
121
l
,
tbBuilderInc
.
getObject
());
// 这个不会在sql才为正常
tbBuilder
.
invoke
(
"incF2"
,
5
l
,
tbBuilderInc
.
getObject
());
tbBuilder
.
invoke
(
"incF3"
,
10
l
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbMapper
.
getObject
(),
"updateWithVersionByExampleSelective"
,
100L
,
tbBuilder
.
invoke
(
"build"
),
tbExample
.
getObject
());
Assert
.
assertEquals
(
sql
,
"update tb SET inc_f1 = inc_f1 + 1, id = 1, inc_f2 = inc_f2 + 5 , inc_f3 = 10 WHERE inc_f1 = 100 and ( ( id = '1' ) )"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbMapper
.
invoke
(
"updateWithVersionByExampleSelective"
,
100L
,
tbBuilder
.
invoke
(
"build"
),
tbExample
.
getObject
());
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是0
result
=
tbMapper
.
invoke
(
"updateWithVersionByExampleSelective"
,
0L
,
tbBuilder
.
invoke
(
"build"
),
tbExample
.
getObject
());
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
1
);
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f2"
),
7
);
}
});
// 测试updateWithVersionByExample
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbMapper"
)));
ObjectUtil
tbExample
=
new
ObjectUtil
(
loader
,
packagz
+
".TbExample"
);
ObjectUtil
criteria
=
new
ObjectUtil
(
tbExample
.
invoke
(
"createCriteria"
));
criteria
.
invoke
(
"andIdEqualTo"
,
1
l
);
ObjectUtil
tbBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder$Inc#INC"
);
tbBuilder
.
invoke
(
"id"
,
1L
);
tbBuilder
.
invoke
(
"incF1"
,
121
l
,
tbBuilderInc
.
getObject
());
// 这个不会在sql才为正常
tbBuilder
.
invoke
(
"incF2"
,
5
l
,
tbBuilderInc
.
getObject
());
tbBuilder
.
invoke
(
"incF3"
,
10
l
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbMapper
.
getObject
(),
"updateWithVersionByExample"
,
100L
,
tbBuilder
.
invoke
(
"build"
),
tbExample
.
getObject
());
Assert
.
assertEquals
(
sql
,
"update tb set inc_f1 = inc_f1 + 1, id = 1, field1 = 'null', inc_f2 = inc_f2 + 5 , inc_f3 = 10 WHERE inc_f1 = 100 and ( ( id = '1' ) )"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbMapper
.
invoke
(
"updateWithVersionByExample"
,
100L
,
tbBuilder
.
invoke
(
"build"
),
tbExample
.
getObject
());
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是0
result
=
tbMapper
.
invoke
(
"updateWithVersionByExample"
,
0L
,
tbBuilder
.
invoke
(
"build"
),
tbExample
.
getObject
());
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
1
);
}
});
// 测试withBLOBs两种情况之一:无BLOBs方式
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbBlobsMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbBlobsMapper"
)));
ObjectUtil
tbBlobsExample
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobsExample"
);
ObjectUtil
criteria
=
new
ObjectUtil
(
tbBlobsExample
.
invoke
(
"createCriteria"
));
criteria
.
invoke
(
"andIdEqualTo"
,
1
l
);
ObjectUtil
tbBlobsWithBLOBsBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobsWithBLOBs$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobs$Builder$Inc#INC"
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"id"
,
1L
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF2"
,
5L
,
tbBuilderInc
.
getObject
());
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF3"
,
10L
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbBlobsMapper
.
getObject
(),
"updateWithVersionByExample"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
),
tbBlobsExample
.
getObject
());
Assert
.
assertEquals
(
sql
,
"update tb_blobs set inc_f1 = inc_f1 + 1, id = 1, field1 = 'null', inc_f2 = inc_f2 + 5 , inc_f3 = 10 WHERE inc_f1 = 100 and ( ( id = '1' ) )"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByExample"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
),
tbBlobsExample
.
getObject
());
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是1
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByExample"
,
1L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
),
tbBlobsExample
.
getObject
());
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb_blobs where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
2
);
}
});
// 测试withBLOBs两种情况之一:有BLOBs方式
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbBlobsMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbBlobsMapper"
)));
ObjectUtil
tbBlobsExample
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobsExample"
);
ObjectUtil
criteria
=
new
ObjectUtil
(
tbBlobsExample
.
invoke
(
"createCriteria"
));
criteria
.
invoke
(
"andIdEqualTo"
,
1
l
);
ObjectUtil
tbBlobsWithBLOBsBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobsWithBLOBs$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobs$Builder$Inc#INC"
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"id"
,
1L
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF2"
,
5L
,
tbBuilderInc
.
getObject
());
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF3"
,
10L
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"field1"
,
"ts1"
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbBlobsMapper
.
getObject
(),
"updateWithVersionByExampleWithBLOBs"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
),
tbBlobsExample
.
getObject
());
Assert
.
assertEquals
(
sql
,
"update tb_blobs set inc_f1 = inc_f1 + 1, id = 1, field1 = 'ts1', inc_f2 = inc_f2 + 5 , inc_f3 = 10, field2 = 'null', field3 = 'null' WHERE inc_f1 = 100 and ( ( id = '1' ) )"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByExampleWithBLOBs"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
),
tbBlobsExample
.
getObject
());
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是1
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByExampleWithBLOBs"
,
1L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
),
tbBlobsExample
.
getObject
());
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb_blobs where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
2
);
Assert
.
assertEquals
(
rs
.
getString
(
"field1"
),
"ts1"
);
}
});
// 测试updateWithVersionByPrimaryKeySelective
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbMapper"
)));
ObjectUtil
tbBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder$Inc#INC"
);
tbBuilder
.
invoke
(
"id"
,
1L
);
tbBuilder
.
invoke
(
"incF1"
,
121
l
,
tbBuilderInc
.
getObject
());
// 这个不会在sql才为正常
tbBuilder
.
invoke
(
"incF2"
,
5
l
,
tbBuilderInc
.
getObject
());
tbBuilder
.
invoke
(
"incF3"
,
10
l
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbMapper
.
getObject
(),
"updateWithVersionByPrimaryKeySelective"
,
100L
,
tbBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
sql
,
"update tb SET inc_f1 = inc_f1 + 1, inc_f2 = inc_f2 + 5 , inc_f3 = 10 where inc_f1 = 100 and id = 1"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbMapper
.
invoke
(
"updateWithVersionByPrimaryKeySelective"
,
100L
,
tbBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是0
result
=
tbMapper
.
invoke
(
"updateWithVersionByPrimaryKeySelective"
,
0L
,
tbBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
1
);
}
});
// 测试updateWithVersionByPrimaryKey
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbMapper"
)));
ObjectUtil
tbBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".Tb$Builder$Inc#INC"
);
tbBuilder
.
invoke
(
"id"
,
1L
);
tbBuilder
.
invoke
(
"incF1"
,
121
l
,
tbBuilderInc
.
getObject
());
// 这个不会在sql才为正常
tbBuilder
.
invoke
(
"incF2"
,
5
l
,
tbBuilderInc
.
getObject
());
tbBuilder
.
invoke
(
"incF3"
,
10
l
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbMapper
.
getObject
(),
"updateWithVersionByPrimaryKey"
,
100L
,
tbBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
sql
,
"update tb set inc_f1 = inc_f1 + 1, field1 = 'null', inc_f2 = inc_f2 + 5 , inc_f3 = 10 where inc_f1 = 100 and id = 1"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbMapper
.
invoke
(
"updateWithVersionByPrimaryKey"
,
100L
,
tbBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是0
result
=
tbMapper
.
invoke
(
"updateWithVersionByPrimaryKey"
,
0L
,
tbBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
1
);
}
});
// 测试withBLOBs两种情况之一:无BLOBs方式
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbBlobsMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbBlobsMapper"
)));
ObjectUtil
tbBlobsWithBLOBsBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobsWithBLOBs$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobs$Builder$Inc#INC"
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"id"
,
1L
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF2"
,
5L
,
tbBuilderInc
.
getObject
());
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF3"
,
10L
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbBlobsMapper
.
getObject
(),
"updateWithVersionByPrimaryKey"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
sql
,
"update tb_blobs set inc_f1 = inc_f1 + 1, field1 = 'null', inc_f2 = inc_f2 + 5 , inc_f3 = 10 where inc_f1 = 100 and id = 1"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByPrimaryKey"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是1
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByPrimaryKey"
,
1L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb_blobs where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
2
);
}
});
// 测试withBLOBs两种情况之一:有BLOBs方式
tool
.
generate
(()
->
DBHelper
.
createDB
(
"scripts/OptimisticLockerPlugin/init.sql"
),
new
AbstractShellCallback
()
{
@Override
public
void
reloadProject
(
SqlSession
sqlSession
,
ClassLoader
loader
,
String
packagz
)
throws
Exception
{
ObjectUtil
tbBlobsMapper
=
new
ObjectUtil
(
sqlSession
.
getMapper
(
loader
.
loadClass
(
packagz
+
".TbBlobsMapper"
)));
ObjectUtil
tbBlobsWithBLOBsBuilder
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobsWithBLOBs$Builder"
);
ObjectUtil
tbBuilderInc
=
new
ObjectUtil
(
loader
,
packagz
+
".TbBlobs$Builder$Inc#INC"
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"id"
,
1L
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF2"
,
5L
,
tbBuilderInc
.
getObject
());
tbBlobsWithBLOBsBuilder
.
invoke
(
"incF3"
,
10L
);
tbBlobsWithBLOBsBuilder
.
invoke
(
"field1"
,
"ts1"
);
// sql
String
sql
=
SqlHelper
.
getFormatMapperSql
(
tbBlobsMapper
.
getObject
(),
"updateWithVersionByPrimaryKeyWithBLOBs"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
sql
,
"update tb_blobs set inc_f1 = inc_f1 + 1, field1 = 'ts1', inc_f2 = inc_f2 + 5 , inc_f3 = 10, field2 = 'null', field3 = 'null' where inc_f1 = 100 and id = 1"
);
// 执行一次,因为版本号100不存在所以应该返回0
Object
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByPrimaryKeyWithBLOBs"
,
100L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
0
);
// id = 1 的版本号应该是1
result
=
tbBlobsMapper
.
invoke
(
"updateWithVersionByPrimaryKeyWithBLOBs"
,
1L
,
tbBlobsWithBLOBsBuilder
.
invoke
(
"build"
));
Assert
.
assertEquals
(
result
,
1
);
// 执行完成后版本号应该加1
ResultSet
rs
=
DBHelper
.
execute
(
sqlSession
.
getConnection
(),
"select * from tb_blobs where id = 1"
);
rs
.
first
();
Assert
.
assertEquals
(
rs
.
getInt
(
"inc_f1"
),
2
);
Assert
.
assertEquals
(
rs
.
getString
(
"field1"
),
"ts1"
);
}
});
}
}
}
\ No newline at end of file
src/test/resources/scripts/OptimisticLockerPlugin/init.sql
View file @
a73bea39
...
@@ -31,7 +31,7 @@ CREATE TABLE `tb` (
...
@@ -31,7 +31,7 @@ CREATE TABLE `tb` (
-- ----------------------------
-- ----------------------------
-- Records of tb
-- Records of tb
-- ----------------------------
-- ----------------------------
INSERT
INTO
`tb`
VALUES
(
'1'
,
'fd1'
,
'0'
,
'
0
'
,
'0'
);
INSERT
INTO
`tb`
VALUES
(
'1'
,
'fd1'
,
'0'
,
'
2
'
,
'0'
);
INSERT
INTO
`tb`
VALUES
(
'2'
,
'fd2'
,
'1'
,
'2'
,
'3'
);
INSERT
INTO
`tb`
VALUES
(
'2'
,
'fd2'
,
'1'
,
'2'
,
'3'
);
INSERT
INTO
`tb`
VALUES
(
'3'
,
null
,
'3'
,
'2'
,
'1'
);
INSERT
INTO
`tb`
VALUES
(
'3'
,
null
,
'3'
,
'2'
,
'1'
);
INSERT
INTO
`tb`
VALUES
(
'4'
,
'fd3'
,
'1'
,
'1'
,
'1'
);
INSERT
INTO
`tb`
VALUES
(
'4'
,
'fd3'
,
'1'
,
'1'
,
'1'
);
...
...
src/test/resources/scripts/OptimisticLockerPlugin/mybatis-generator-with-IncrementsPlugin.xml
0 → 100644
View file @
a73bea39
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright (c) 2018.
~
~ Licensed under the Apache License, Version 2.0 (the "License");
~ you may not use this file except in compliance with the License.
~ You may obtain a copy of the License at
~
~ http://www.apache.org/licenses/LICENSE-2.0
~
~ Unless required by applicable law or agreed to in writing, software
~ distributed under the License is distributed on an "AS IS" BASIS,
~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
~ See the License for the specific language governing permissions and
~ limitations under the License.
-->
<!DOCTYPE generatorConfiguration
PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorConfiguration>
<properties
resource=
"db.properties"
/>
<!--导入属性配置 -->
<context
id=
"default"
targetRuntime=
"MyBatis3"
>
<!-- 插件 -->
<plugin
type=
"com.itfsw.mybatis.generator.plugins.OptimisticLockerPlugin"
/>
<plugin
type=
"com.itfsw.mybatis.generator.plugins.IncrementsPlugin"
/>
<plugin
type=
"com.itfsw.mybatis.generator.plugins.ModelBuilderPlugin"
/>
<!--jdbc的数据库连接 -->
<jdbcConnection
driverClass=
"${driver}"
connectionURL=
"${url}"
userId=
"${username}"
password=
"${password}"
/>
<!-- Model模型生成器,用来生成含有主键key的类,记录类 以及查询Example类
targetPackage 指定生成的model生成所在的包名
targetProject 指定在该项目下所在的路径 -->
<javaModelGenerator
targetPackage=
""
targetProject=
""
>
<!-- 是否对model添加 构造函数 -->
<property
name=
"constructorBased"
value=
"true"
/>
<!-- 给Model添加一个父类 -->
<!--<property name="rootClass" value="com.itfsw.base"/>-->
</javaModelGenerator>
<!--Mapper映射文件生成所在的目录 为每一个数据库的表生成对应的SqlMap文件 -->
<sqlMapGenerator
targetPackage=
""
targetProject=
""
/>
<!-- 客户端代码,生成易于使用的针对Model对象和XML配置文件 的代码
type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper对象
type="MIXEDMAPPER",生成基于注解的Java Model 和相应的Mapper对象
type="XMLMAPPER",生成SQLMap XML文件和独立的Mapper接口 -->
<javaClientGenerator
targetPackage=
""
targetProject=
""
type=
"XMLMAPPER"
/>
<!-- +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 要自动生成的表 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ -->
<table
tableName=
"tb"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<property
name=
"incrementsColumns"
value=
"inc_f1,inc_f2"
/>
<generatedKey
column=
"id"
sqlStatement=
"MySql"
identity=
"true"
/>
</table>
<table
tableName=
"tb_keys"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<property
name=
"incrementsColumns"
value=
"inc_f2"
/>
</table>
<table
tableName=
"tb_blobs"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<property
name=
"incrementsColumns"
value=
"inc_f2"
/>
<generatedKey
column=
"id"
sqlStatement=
"MySql"
identity=
"true"
/>
</table>
</context>
</generatorConfiguration>
\ No newline at end of file
src/test/resources/scripts/OptimisticLockerPlugin/mybatis-generator-with-unfind-version-column.xml
0 → 100644
View file @
a73bea39
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright (c) 2018.
~
~ Licensed under the Apache License, Version 2.0 (the "License");
~ you may not use this file except in compliance with the License.
~ You may obtain a copy of the License at
~
~ http://www.apache.org/licenses/LICENSE-2.0
~
~ Unless required by applicable law or agreed to in writing, software
~ distributed under the License is distributed on an "AS IS" BASIS,
~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
~ See the License for the specific language governing permissions and
~ limitations under the License.
-->
<!DOCTYPE generatorConfiguration
PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorConfiguration>
<properties
resource=
"db.properties"
/>
<!--导入属性配置 -->
<context
id=
"default"
targetRuntime=
"MyBatis3"
>
<!-- 插件 -->
<plugin
type=
"com.itfsw.mybatis.generator.plugins.OptimisticLockerPlugin"
/>
<!--jdbc的数据库连接 -->
<jdbcConnection
driverClass=
"${driver}"
connectionURL=
"${url}"
userId=
"${username}"
password=
"${password}"
/>
<!-- Model模型生成器,用来生成含有主键key的类,记录类 以及查询Example类
targetPackage 指定生成的model生成所在的包名
targetProject 指定在该项目下所在的路径 -->
<javaModelGenerator
targetPackage=
""
targetProject=
""
>
<!-- 是否对model添加 构造函数 -->
<property
name=
"constructorBased"
value=
"true"
/>
<!-- 给Model添加一个父类 -->
<!--<property name="rootClass" value="com.itfsw.base"/>-->
</javaModelGenerator>
<!--Mapper映射文件生成所在的目录 为每一个数据库的表生成对应的SqlMap文件 -->
<sqlMapGenerator
targetPackage=
""
targetProject=
""
/>
<!-- 客户端代码,生成易于使用的针对Model对象和XML配置文件 的代码
type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper对象
type="MIXEDMAPPER",生成基于注解的Java Model 和相应的Mapper对象
type="XMLMAPPER",生成SQLMap XML文件和独立的Mapper接口 -->
<javaClientGenerator
targetPackage=
""
targetProject=
""
type=
"XMLMAPPER"
/>
<!-- +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 要自动生成的表 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ -->
<table
tableName=
"tb"
>
<property
name=
"versionColumn"
value=
"ttssss"
/>
<generatedKey
column=
"id"
sqlStatement=
"MySql"
identity=
"true"
/>
</table>
<table
tableName=
"tb_keys"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
</table>
<table
tableName=
"tb_blobs"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<generatedKey
column=
"id"
sqlStatement=
"MySql"
identity=
"true"
/>
</table>
</context>
</generatorConfiguration>
\ No newline at end of file
src/test/resources/scripts/OptimisticLockerPlugin/mybatis-generator.xml
View file @
a73bea39
...
@@ -53,8 +53,6 @@
...
@@ -53,8 +53,6 @@
</table>
</table>
<table
tableName=
"tb_keys"
>
<table
tableName=
"tb_keys"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<generatedKey
column=
"id"
sqlStatement=
"MySql"
identity=
"true"
/>
</table>
</table>
<table
tableName=
"tb_blobs"
>
<table
tableName=
"tb_blobs"
>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
<property
name=
"versionColumn"
value=
"inc_f1"
/>
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment