摘要:本文主要向大家介绍了JAVA语言之java直接调用并执行sql脚本,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。
本文主要向大家介绍了JAVA语言之java直接调用并执行sql脚本,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。
package com.qfx.test;
import java.io.File;
import java.io.FileReader;
import java.io.Reader;
import java.nio.charset.Charset;
import java.sql.Connection;
import java.sql.DriverManager;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.jdbc.ScriptRunner;
public class ScriptRunnerExecSql {
private static String dbHost="127.0.0.1"; // 数据库地址
private static String dbName="test"; // 数据库名称
private static String userName = "test"; // 登录名称
private static String userPassword = "test111"; // 登录密码
private static String dbPort="3306"; // 数据库端口号
public static void main(String[] args) {
try {
Connection conn =getMySqlConnection();
ScriptRunner runner = new ScriptRunner(conn);
Resources.setCharset(Charset.forName("UTF-8")); //设置字符集,不然中文乱码插入错误
runner.setLogWriter(null);//设置是否输出日志
// 绝对路径读取
// Reader read = new FileReader(new File("f:\\test.sql"));
// 从class目录下直接读取
Reader read = Resources.getResourceAsReader("test.sql");
runner.runScript(read);
runner.closeConnection();
conn.close();
System.out.println("sql脚本执行完毕");
} catch (Exception e) {
System.out.println("sql脚本执行发生异常");
e.printStackTrace();
}
}
/**
* @功能描述: 获取数据库连接
*
* @return
* @throws Exception
*/
public static Connection getMySqlConnection() throws Exception {
Class.forName("com.mysql.jdbc.Driver");
String url="jdbc:mysql://"+dbHost+":"+dbPort+"/"+dbName+"?useUnicode=true&characterEncoding=utf-8&port="+dbPort+"&autoReconnect=true";
return DriverManager.getConnection(url,userName,userPassword);
}
}
本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注编程语言JAVA频道!
您输入的评论内容中包含违禁敏感词
我知道了
请输入正确的手机号码
请输入正确的验证码
您今天的短信下发次数太多了,明天再试试吧!
我们会在第一时间安排职业规划师联系您!
您也可以联系我们的职业规划师咨询:
版权所有 职坐标-一站式IT培训就业服务领导者 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
沪公网安备 31011502005948号