Java JDBC
2016-05-26 00:00
369 查看
摘要: java JDBC
package com.sunny.test03; import java.sql.*; import java.util.Iterator; import java.util.LinkedList; import java.util.Map; import java.util.Set; public class DateBaseAction { static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; static final String DB_URL = "jdbc:mysql://localhost"; private String USER;// 数据库用户名 private String PASS;// 数据库密码 private String DateBaseName = null; private String TableName = null; public DateBaseAction(String uSER, String pASS, String dateBaseName, String tableName) { super(); setDateBaseName(dateBaseName); setTableName(tableName); setUSER(uSER); setPASS(pASS); } public DateBaseAction() { super(); } public String getDateBaseName() { return DateBaseName; } public void setDateBaseName(String dateBaseName) { DateBaseName = dateBaseName; } public String getTableName() { return TableName; } public void setTableName(String tableName) { TableName = tableName; } public String getUSER() { return USER; } public void setUSER(String uSER) { USER = uSER; } public String getPASS() { return PASS; } public void setPASS(String pASS) { PASS = pASS; } public void InsertData(LinkedList<String> datalink,Map<String,String> map) { StringBuilder Vans=new StringBuilder(""); Set<String> keys=map.keySet(); Iterator<String> ite=keys.iterator(); int j=0; while(ite.hasNext()) { String strr=ite.next(); if(!strr.equals("id")) { if(j==0) Vans.append(strr); else Vans.append(",").append(strr); j++; } } Connection conn = null; Statement stmt = null; try{ Class.forName(JDBC_DRIVER); System.out.println("Connecting to a selected database..."); if(DateBaseName.equals(null)) { System.out.println("DateBase is null,please create a new database"); } else { String NewURL = DB_URL + "/" + DateBaseName; conn = DriverManager.getConnection(NewURL, USER, PASS); System.out.println("Connected database successfully..."); System.out.println("Inserting records into the table..."); stmt = conn.createStatement(); StringBuilder tf=new StringBuilder(""); tf.append("INSERT INTO ").append(TableName).append("(").append(Vans.toString()).append(")").append(" VALUES("); System.out.println(tf); Iterator<String> s=datalink.iterator(); int i=0; //Pattern p=Pattern.compile("[0-9]*"); while(s.hasNext()) { String rs=s.next(); //if(p.matcher(rs).matches()) //{if(i==0) tf.append(rs);else tf.append(",").append(rs);} //else //{if(i==0) tf.append("'").append(rs).append("'");else tf.append(",").append("'").append(rs).append("'");} //i++; if(i==0) tf.append(rs); else tf.append(",").append(rs); i++; } tf.append(")"); String sr=tf.toString(); System.out.println(sr); stmt.executeUpdate(sr); System.out.println("Inserted records into the table..."); } }catch(Exception se){ se.printStackTrace(); }finally{ try{ if(stmt!=null) conn.close(); }catch(SQLException se){ } try{ if(conn!=null) conn.close(); }catch(SQLException se){ se.printStackTrace(); } } System.out.println("Goodbye!"); } public void CreateTable(Map<String, String> param) { Connection conn = null; Statement stmt = null; try { Class.forName(JDBC_DRIVER); if (DateBaseName.equals(null)) { System.out.println("DateBase is null,please create a new database"); } else { String NewURL = DB_URL + "/" + DateBaseName; System.out.println("Connecting to a selected database..."); conn = DriverManager.getConnection(NewURL, USER, PASS); System.out.println("Connected database successfully..."); System.out.println("Creating table in given database..."); stmt = conn.createStatement(); StringBuilder sql = new StringBuilder(""); sql.append("CREATE TABLE ").append(TableName).append(" "); sql.append("("); Set<String> keys = param.keySet(); Iterator<String> iter = keys.iterator(); while (iter.hasNext()) { String str = iter.next(); String strval = param.get(str); sql.append(str).append(" ").append(strval).append(","); } sql.append("PRIMARY KEY(id))"); // String sql = "CREATE TABLE REGISTRATION " + "(id INTEGER not // NULL, " + " first VARCHAR(255), "+ " last VARCHAR(255), " + " // age INTEGER, " + " PRIMARY KEY ( id ))"; String rln=sql.toString(); stmt.executeUpdate(rln); System.out.println("Created table in given database..."); } } catch (Exception se) { se.printStackTrace(); } finally { try { if (stmt != null) conn.close(); } catch (SQLException se) { } try { if (conn != null) conn.close(); } catch (SQLException se) { se.printStackTrace(); } } System.out.println("Goodbye!"); } public void CreateDatabase() { Connection conn = null; Statement stmt = null; try { Class.forName(JDBC_DRIVER); // Class.forName("JDBC_DRIVER");// Class // class2=Class.forName(JDBC_DRIVER);// Class // class2=Class.forName("com.mysql.jdbc.Driver");// Class // class3=JDBC_DRIVER.getClass(); System.out.println("Connecting to database..."); conn = DriverManager.getConnection(DB_URL, USER, PASS); System.out.println("Creating database..."); stmt = conn.createStatement(); String sql = "CREATE DATABASE " + DateBaseName; stmt.executeUpdate(sql); System.out.println("Database created " + DateBaseName + " successfully..."); } catch (Exception e) { e.printStackTrace(); } finally { try { if (stmt != null) stmt.close(); } catch (SQLException se2) { } try { if (conn != null) conn.close(); } catch (SQLException se) { se.printStackTrace(); } } System.out.println("Goodbye!"); } }
相关文章推荐
- jdbc中的Statement和PreparedStatement接口对象
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- c++11 + SDL2 + ffmpeg +OpenAL + java = Android播放器
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序