您的位置:首页 > 编程语言 > Java开发

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!");
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  java jdbc