/**
*
*/
import java.sql.*
;
import java.util.Date;
import org.omg.CORBA.PUBLIC_MEMBER;
/**
* @author Administrator
*
*/
public class Mysql {
public void Chaxun() {
try {
Class.forName("com.mysql.jdbc.Driver"
);
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
String url="jdbc:mysql://localhost:3306/beijing";
//jabc的路径
Connection connection;
try {
connection=DriverManager.getConnection(url, "root", "liwanlei"
);
Statement statement=
connection.createStatement();
String sql="select * from student where id=1"
;
ResultSet resultSet=
statement.executeQuery(sql);
if (resultSet.next()) {
System.out.println(resultSet.getString("name"
));
}
statement.close();
connection.close();
} catch (Exception e) {
// TODO: handle exception
System.out.println(e);
}
}
public void Change() {
try {
Class.forName("com.mysql.jdbc.Driver"
);
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
System.out.println("异常"
);
}
String url="jdbc:mysql://localhost:3306/beijing";
//jabc的路径
Connection connection;
try {
connection=DriverManager.getConnection(url, "root", "liwanlei"
);
Statement statement=
connection.createStatement();
String sql="UPDATE student SET name=? WHERE id=?"
;
PreparedStatement preparedStatement=
connection.prepareStatement(sql);
preparedStatement.setString(1, "liwanlei"
);
preparedStatement.setInt(2, 1
);
preparedStatement.executeUpdate();
System.out.println("ok"
);}
catch (Exception e) {
// TODO: handle exception
System.out.println("异常"
);
}
}
public void Adddate() {
Date aDate=
new Date();
try {
Class.forName("com.mysql.jdbc.Driver"
);
} catch (Exception e) {
// TODO: handle exception
System.out.println("加载驱动失败"
);
}
String url="jdbc:mysql://localhost:3306/beijing"
;
Connection connection;
try {
connection=DriverManager.getConnection(url, "root", "liwanlei"
);
Statement statement=
connection.createStatement();
String sql="insert into student (id,name,age,address) values (?,?,?,?)"
;
PreparedStatement preparedStatement=
connection.prepareStatement(sql);
for(
int i=1;i<10;i++
){
preparedStatement.setInt(1
, i);
preparedStatement.setString(2, "liwanddlei"+
i);
preparedStatement.setInt(3, i*333
);
preparedStatement.setString(4, "beijiddng"+
i);
preparedStatement.executeUpdate();
}
preparedStatement.close();
connection.close();
Date date=
new Date();
System.out.println((date.getTime()-
aDate.getTime()));
System.out.println("插入慕成功"
);
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
Mysql mysql=
new Mysql();
mysql.Adddate();
}
}
多线程插入版本
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.util.Date;
/**
*
*/
/**
* @author lileilei
*Threadmyql.java
*2017年12月9日
*/
public class Threadmyql extends Thread{
@Override
public void run() {
Date aDate=new Date();
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (Exception e) {
// TODO: handle exception
System.out.println("加载驱动失败");
}
String url="jdbc:mysql://localhost:3306/beijing";
Connection connection;
try {
connection=DriverManager.getConnection(url, "root", "liwanlei");
Statement statement=connection.createStatement();
String sql="insert into student (id,name,age,address) values (?,?,?,?)";
PreparedStatement preparedStatement=connection.prepareStatement(sql);
for(int i=1;i<100000;i++){
preparedStatement.setInt(1, i);
preparedStatement.setString(2, "asdasdasd"+i);
preparedStatement.setInt(3, i*333);
preparedStatement.setString(4, "asdasdasdasdasdasd"+i);
preparedStatement.executeUpdate();
}
preparedStatement.close();
connection.close();
Date date=new Date();
System.out.println((date.getTime()-aDate.getTime())/1000);
System.out.println("插入慕成功");
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
for (int i = 1; i <=10; i++) {
new Threadmyql().start();
}
}
}
数据关联性小,没有必要做性能,做了一会 发现没有必要
java 操作本地数据库 mysql
标签:root getc 2017年 connect [] mysq driver rgs tac