记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
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
董敬伟
liquidnet-bus-v1
Commits
37ed9522
Commit
37ed9522
authored
Jun 06, 2021
by
张国柄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
验票API:验票数据添加UpdatedAt;
SQLMAPPING脚本LOAD调整;
parent
7cf18a2d
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
16 additions
and
33 deletions
+16
-33
SqlMapping.java
.../src/main/java/com/liquidnet/service/base/SqlMapping.java
+16
-33
No files found.
liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/SqlMapping.java
View file @
37ed9522
package
com
.
liquidnet
.
service
.
base
;
package
com
.
liquidnet
.
service
.
base
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
org.apache.logging.log4j.util.PropertiesUtil
;
import
org.springframework.core.io.support.PropertiesLoaderUtils
;
import
java.io.*
;
import
java.io.IOException
;
import
java.net.URL
;
import
java.io.InputStream
;
import
java.io.InputStreamReader
;
import
java.io.Serializable
;
import
java.nio.charset.StandardCharsets
;
import
java.nio.charset.StandardCharsets
;
import
java.util.HashMap
;
import
java.util.LinkedList
;
import
java.util.LinkedList
;
import
java.util.Map
;
import
java.util.Properties
;
import
java.util.Properties
;
public
class
SqlMapping
{
public
class
SqlMapping
{
private
static
final
String
sqlMapDir
=
"sqlmap"
;
private
static
Map
<
String
,
String
>
sqlPropertiesMap
=
new
HashMap
<>();
static
{
static
{
try
{
reload
();
URL
url
=
PropertiesUtil
.
class
.
getClassLoader
().
getResource
(
sqlMapDir
);
System
.
out
.
println
(
"sm.url:"
+
url
);
if
(
null
!=
url
)
{
System
.
out
.
println
(
"sm.url:"
+
url
.
getPath
()
+
",file:"
+
url
.
getFile
());
File
file
=
new
File
(
url
.
getFile
());
if
(
file
.
exists
()
&&
file
.
isDirectory
())
{
System
.
out
.
println
(
"sm.url:"
+
file
.
getPath
());
File
[]
files
=
file
.
listFiles
();
for
(
File
f
:
files
)
{
System
.
out
.
println
(
"sm.url:"
+
f
.
getPath
());
if
(
f
.
isFile
()
&&
f
.
getName
().
endsWith
(
"properties"
))
{
Properties
props
=
PropertiesLoaderUtils
.
loadAllProperties
(
sqlMapDir
.
concat
(
"/"
)
+
f
.
getName
());
for
(
Object
key
:
props
.
keySet
())
{
String
keyStr
=
key
.
toString
();
String
value
=
props
.
getProperty
(
keyStr
);
sqlPropertiesMap
.
put
(
keyStr
,
value
);
}
}
}
}
}
}
private
static
Properties
sqlsProperties
;
System
.
out
.
printf
(
"sqlPropertiesMap init count: %s\n"
,
sqlPropertiesMap
.
size
());
public
static
void
reload
()
{
sqlsProperties
=
new
Properties
();
InputStream
in
=
ErrorMapping
.
class
.
getClassLoader
().
getResourceAsStream
(
"sqlmap.properties"
);
try
{
sqlsProperties
.
load
(
new
InputStreamReader
(
in
,
StandardCharsets
.
UTF_8
));
System
.
out
.
printf
(
"errorsProperties init count: %s\n"
,
sqlsProperties
.
size
());
}
catch
(
IOException
e
)
{
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
e
.
printStackTrace
();
}
}
}
}
public
static
String
get
(
String
sql
)
{
public
static
String
get
(
String
sql
)
{
return
sqlPropertiesMap
.
get
(
sql
);
return
(
String
)
sqlsProperties
.
get
(
sql
);
}
}
public
static
class
SqlMessage
implements
Cloneable
,
Serializable
{
public
static
class
SqlMessage
implements
Cloneable
,
Serializable
{
...
@@ -94,7 +77,7 @@ public class SqlMapping {
...
@@ -94,7 +77,7 @@ public class SqlMapping {
public
static
String
get
(
String
sqlKey
,
Object
...
params
)
{
public
static
String
get
(
String
sqlKey
,
Object
...
params
)
{
LinkedList
<
String
>
sqls
=
new
LinkedList
<>();
LinkedList
<
String
>
sqls
=
new
LinkedList
<>();
sqls
.
add
(
sqlPropertiesMap
.
get
(
sqlKey
));
sqls
.
add
(
(
String
)
sqlsProperties
.
get
(
sqlKey
));
LinkedList
<
Object
[]>
paramsList
=
new
LinkedList
<>();
LinkedList
<
Object
[]>
paramsList
=
new
LinkedList
<>();
paramsList
.
add
(
params
);
paramsList
.
add
(
params
);
LinkedList
<
Object
[]>[]
args
=
new
LinkedList
[]{
paramsList
};
LinkedList
<
Object
[]>[]
args
=
new
LinkedList
[]{
paramsList
};
...
@@ -107,7 +90,7 @@ public class SqlMapping {
...
@@ -107,7 +90,7 @@ public class SqlMapping {
public
static
String
get
(
String
sqlKey
,
LinkedList
<
Object
[]>
paramsList
)
{
public
static
String
get
(
String
sqlKey
,
LinkedList
<
Object
[]>
paramsList
)
{
LinkedList
<
String
>
sqls
=
new
LinkedList
<>();
LinkedList
<
String
>
sqls
=
new
LinkedList
<>();
sqls
.
add
(
sqlPropertiesMap
.
get
(
sqlKey
));
sqls
.
add
(
(
String
)
sqlsProperties
.
get
(
sqlKey
));
LinkedList
<
Object
[]>[]
args
=
new
LinkedList
[]{
paramsList
};
LinkedList
<
Object
[]>[]
args
=
new
LinkedList
[]{
paramsList
};
SqlMapping
.
SqlMessage
sqlMessage
=
SqlMapping
.
SqlMessage
.
getInstance
();
SqlMapping
.
SqlMessage
sqlMessage
=
SqlMapping
.
SqlMessage
.
getInstance
();
...
...
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