eccel表格数据上传到mysql中_Excel表中的数据导入mysql数据库

朴灿烈づ我的快乐病毒、 2022-11-06 02:56 198阅读 0赞

packagecom.chen.toolsbean;importjava.io.IOException;importjava.io.InputStream;importjava.sql.CallableStatement;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.sql.Statement;importjava.util.Properties;public classSqlHelper \{//定义变量

private static Connection ct = null;//大多数情况下用preparedstatement替代statement

private static PreparedStatement ps = null;private static ResultSet rs = null;//连接数据库的参数

privatestaticString url = "";private static String username = "";private static String driver = "";private static String passwd = "";private static CallableStatement cs = null;public staticCallableStatement getCs() \{returncs;

\}private static Properties pp = null;private static InputStream fis = null;//加载驱动，只需要一次，用静态代码块

static\{try\{//从dbinfo.propertiespp= newProperties();

fis= SqlHelper.class.getClassLoader().getResourceAsStream("com/chen/toolsbean/dbinfo.properties");//fis = new FileInputStream();

pp.load(fis);

url= pp.getProperty("url");

username= pp.getProperty("username");

driver= pp.getProperty("driver");

passwd= pp.getProperty("password");

Class.forName(driver);

\}catch(Exception e) \{

e.printStackTrace();

\}finally\{try\{

fis.close();

\}catch(IOException e) \{

e.printStackTrace();

fis= null;//垃圾回收站上收拾\}

\}//得到连接

publicstaticConnection getConnection() \{try\{

ct=DriverManager.getConnection(url, username, passwd);

\}catch(Exception e) \{

e.printStackTrace();

\}returnct;

\}//\*\*\*\*\*\*\*\*\*\*\*\*\*callPro1存储过程函数1\*\*\*\*\*\*\*\*\*\*\*\*\*

public staticCallableStatement callPro1(String sql, String\[\] parameters) \{try\{

ct=getConnection();

cs=ct.prepareCall(sql);if (parameters != null) \{for (int i = 0; i < parameters.length; i++) \{

cs.setObject(i+ 1, parameters\[i\]);

cs.execute();

\}catch(Exception e) \{

e.printStackTrace();throw newRuntimeException(e.getMessage());

\}finally\{

close(rs, cs, ct);

\}returncs;

\}//\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*callpro2存储过程2\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

public staticCallableStatement callPro2(String sql, String\[\] inparameters,

Integer\[\] outparameters) \{try\{

ct=getConnection();

cs=ct.prepareCall(sql);if (inparameters != null) \{for (int i = 0; i < inparameters.length; i++) \{

cs.setObject(i+ 1, inparameters\[i\]);

\}//cs.registerOutparameter(2,oracle.jdbc.OracleTypes.CURSOR);

if (outparameters != null) \{for (int i = 0; i < outparameters.length; i++) \{

cs.registerOutParameter(inparameters.length+ 1 +i,

outparameters\[i\]);

cs.execute();

\}catch(Exception e) \{

e.printStackTrace();throw newRuntimeException(e.getMessage());

\}finally\{

\}returncs;

\}public staticResultSet executeQuery(String sql, String\[\] parameters) \{try\{

ct=getConnection();

ps=ct.prepareStatement(sql);if (parameters != null) \{for (int i = 0; i < parameters.length; i++) \{

ps.setString(i+ 1, parameters\[i\]);

rs=ps.executeQuery();

\}catch(Exception e) \{

e.printStackTrace();throw newRuntimeException(e.getMessage());

\}finally\{

\}returnrs;

\}public staticConnection getCt() \{returnct;

\}public staticPreparedStatement getPs() \{returnps;

\}public staticResultSet getRs() \{returnrs;

\}public static voidexecuteUpdate2(String\[\] sql, String\[\]\[\] parameters) \{try\{

ct=getConnection();

ct.setAutoCommit(false);for (int i = 0; i < sql.length; i++) \{if (null !=parameters\[i\]) \{

ps=ct.prepareStatement(sql\[i\]);for (int j = 0; j < parameters\[i\].length; j++) \{

ps.setString(j+ 1, parameters\[i\]\[j\]);

ps.executeUpdate();

ct.commit();

\}catch(Exception e) \{

e.printStackTrace();try\{

ct.rollback();

\}catch(SQLException e1) \{

e1.printStackTrace();

\}throw newRuntimeException(e.getMessage());

\}finally\{

close(rs, ps, ct);

\}//先写一个update、delete、insert//sql格式：update 表名 set 字段名 =？where 字段=？//parameter神应该是(”abc“,23)

public static voidexecuteUpdate(String sql, String\[\] parameters) \{try\{

ct=getConnection();ps=ct.prepareStatement(sql);if (parameters != null) \{for (int i = 0; i < parameters.length; i++) \{

ps.setString(i+ 1, parameters\[i\]);

ps.executeUpdate();

\}catch(Exception e) \{

e.printStackTrace();//开发阶段//抛出异常//可以处理，也可以不处理

throw newRuntimeException(e.getMessage());

\}finally\{

close(rs, ps, ct);

\}public static voidclose(ResultSet rs, Statement ps, Connection ct) \{//关闭资源(先开后关)

if (rs != null) \{try\{

rs.close();

\}catch(SQLException e) \{

e.printStackTrace();

rs= null;

\}if (ps != null) \{try\{

ps.close();

\}catch(SQLException e) \{

e.printStackTrace();

ps= null;

\}if (null !=ct) \{try\{

ct.close();

\}catch(SQLException e) \{

e.printStackTrace();

ct= null;

eccel表格数据上传到mysql中_Excel表中的数据导入mysql数据库

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关如何将Excel表格的数据导入到MySql数据库中

相关 java excel mysql_Java将excel中的数据导入到mysql中

相关使用Navicat 导出 MySQL 数据库表结构、表数据到Excel表格中

相关 eccel表格数据上传到mysql中_Excel表中的数据导入mysql数据库

相关 SQL/shell将Excel数据导入到MySQL数据库中

相关如何将Excel表格的数据导入到MySql数据库中

相关【MySQL基础】mysql 导入文件中的数据到数据库表

相关 MySQL--导入Excel表格数据

相关 Java将Excel表格中数据导入至数据库中的表中

相关 Excel表格数据导入到SQLServer数据库