From 6036a3f2b7fba39cb6ec2a6e2a61b5ee06d5076f Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Tue, 30 Nov 2021 10:29:23 +0800
Subject: [PATCH] ftp mysql 连接修改
---
src/main/java/org/springblade/modules/FTP/MysqlCenlint.java | 155 +++++++++++++++++++++++++++++----------------------
1 files changed, 88 insertions(+), 67 deletions(-)
diff --git a/src/main/java/org/springblade/modules/FTP/MysqlCenlint.java b/src/main/java/org/springblade/modules/FTP/MysqlCenlint.java
index d092a4b..3a5cbe8 100644
--- a/src/main/java/org/springblade/modules/FTP/MysqlCenlint.java
+++ b/src/main/java/org/springblade/modules/FTP/MysqlCenlint.java
@@ -38,34 +38,54 @@
mysqlCenlint.userService = this.userService;
}
+ /**
+ * sql 连接
+ * @param sql
+ */
+ public static void sqlConnect(String sql,Integer type){
+ String driver = "com.mysql.cj.jdbc.Driver";
+ String url = sqlConnect; //换成要连接的数据库信息
+ String user = "root";
+ String password = "zhba0728";
+ Connection conn = null;
+ PreparedStatement ps = null;
+ try {
+ Class.forName ( driver );
+ conn = (Connection) DriverManager.getConnection ( url, user, password );
+ if (!conn.isClosed ()) {
+ System.out.println ( "数据库连接成功：" );
+ String sqls = sql;
+ ps = conn.prepareStatement ( sqls );
+ //判断是否为修改，删除
+ if (type==1){
+ //修改删除
+ ps.executeUpdate();
+ }else {
+ //新增
+ ps.execute();
+ }
+ }
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
+ } catch (SQLException e) {
+ e.printStackTrace ();
+ }finally {
+ try {
+ ps.close();
+ conn.close();
+ } catch (SQLException throwables) {
+ throwables.printStackTrace();
+ }
+ }
+ }
+
/**
* 连接mysql数据库 新增
* @param sql
*/
public static void inster(String sql) {
- try {
- int ColumnCount;
- //int RowCount;
- String driver = "com.mysql.cj.jdbc.Driver";
- String url = sqlConnect; //换成要连接的数据库信息
- String user = "root";
- String password = "zhba0728";
- Class.forName ( driver );
- Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
- if (!conn.isClosed ()) {
- System.out.println ( "数据库连接成功：" );
- String sqls = sql; //sql
- PreparedStatement ps = conn.prepareStatement ( sqls );
- boolean execute = ps.execute();
- ps.close ();
- conn.close ();
- }
- } catch (ClassNotFoundException e) {
- e.printStackTrace ();
- } catch (SQLException e) {
- e.printStackTrace ();
- }
+ sqlConnect(sql,2);
try {
Thread.sleep(300);
//对比 sql 字符串，如果是是往用户表里插入保安员数据，则调用公安审查接口
@@ -77,7 +97,6 @@
} catch (InterruptedException e) {
e.printStackTrace();
}
-
}
/**
@@ -177,28 +196,29 @@
* @param sql
*/
public static void update(String sql) {
- try {
- int ColumnCount;
- //int RowCount;
- String driver = "com.mysql.cj.jdbc.Driver";
- String url = sqlConnect; //换成要连接的数据库信息
- String user = "root";
- String password = "zhba0728";
- Class.forName ( driver );
- Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
- if (!conn.isClosed ()) {
- System.out.println ( "数据库连接成功：" );
- String sqls = sql; //sql
- PreparedStatement ps = conn.prepareStatement ( sqls );
- ps.executeUpdate();
- ps.close ();
- conn.close ();
- }
- } catch (ClassNotFoundException e) {
- e.printStackTrace ();
- } catch (SQLException e) {
- e.printStackTrace ();
- }
+ sqlConnect(sql,1);
+// try {
+// int ColumnCount;
+// //int RowCount;
+// String driver = "com.mysql.cj.jdbc.Driver";
+// String url = sqlConnect; //换成要连接的数据库信息
+// String user = "root";
+// String password = "zhba0728";
+// Class.forName ( driver );
+// Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
+// if (!conn.isClosed ()) {
+// System.out.println ( "数据库连接成功：" );
+// String sqls = sql; //sql
+// PreparedStatement ps = conn.prepareStatement ( sqls );
+// ps.executeUpdate();
+// ps.close ();
+// conn.close ();
+// }
+// } catch (ClassNotFoundException e) {
+// e.printStackTrace ();
+// } catch (SQLException e) {
+// e.printStackTrace ();
+// }
}
/**
@@ -206,28 +226,29 @@
* @param sql
*/
public static void delete(String sql) {
- try {
- int ColumnCount;
- //int RowCount;
- String driver = "com.mysql.cj.jdbc.Driver";
- String url = sqlConnect; //换成要连接的数据库信息
- String user = "root";
- String password = "zhba0728";
- Class.forName ( driver );
- Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
- if (!conn.isClosed ()) {
- System.out.println ( "数据库连接成功：" );
- String sqls = sql; //sql
- PreparedStatement ps = conn.prepareStatement ( sqls );
- ps.executeUpdate();
- ps.close ();
- conn.close ();
- }
- } catch (ClassNotFoundException e) {
- e.printStackTrace ();
- } catch (SQLException e) {
- e.printStackTrace ();
- }
+ sqlConnect(sql,1);
+// try {
+// int ColumnCount;
+// //int RowCount;
+// String driver = "com.mysql.cj.jdbc.Driver";
+// String url = sqlConnect; //换成要连接的数据库信息
+// String user = "root";
+// String password = "zhba0728";
+// Class.forName ( driver );
+// Connection conn = (Connection) DriverManager.getConnection ( url, user, password );
+// if (!conn.isClosed ()) {
+// System.out.println ( "数据库连接成功：" );
+// String sqls = sql; //sql
+// PreparedStatement ps = conn.prepareStatement ( sqls );
+// ps.executeUpdate();
+// ps.close ();
+// conn.close ();
+// }
+// } catch (ClassNotFoundException e) {
+// e.printStackTrace ();
+// } catch (SQLException e) {
+// e.printStackTrace ();
+// }
}
/**
--
Gitblit v1.9.3