您的位置:首页 > 数据库

简单JDBC连接数据库

2014-11-24 17:32 239 查看
Java代码


JdbcBatchInsert.java





import java.sql.*;

public class JdbcBatchInsert {

public static void main(String args[]) {

Connection con = null;

Statement st = null;

ResultSet rs = null;

String url = "jdbc:mysql://localhost:3306/";

String db = "komal";

String driver = "com.mysql.jdbc.Driver";

String user = "root";

String pass = "root";

try {

Class.forName(driver);

con = DriverManager.getConnection(url + db, user, pass);

con.setAutoCommit(false);// Disables auto-commit.

st = con.createStatement();

st.addBatch("INSERT INTO person VALUES('4','Komal')");

st.addBatch("INSERT INTO person VALUES('5','Ajay')");

st.addBatch("INSERT INTO person VALUES('6','Santosh')");

st.executeBatch();

String sql = "select * from person";

rs = st.executeQuery(sql);

System.out.println("No \tName");

while (rs.next()) {

System.out.print(rs.getString(1) + " \t");

System.out.println(rs.getString(2));

}

rs.close();

st.close();

con.close();

} catch (Exception e) {

e.printStackTrace();

}

}

}

?************************************************************************?

Java代码


JdbcPreparedstatementAddbatch.java





import java.sql.*;



public class JdbcPreparedstatementAddbatch {



public static void main(String args[]) {



Connection con = null;

PreparedStatement pst = null;

ResultSet rs = null;



String url = "jdbc:mysql://localhost:3306/";

String db = "komal";

String driver = "com.mysql.jdbc.Driver";

String user = "root";

String pass = "root";



try {



Class.forName(driver);

con = DriverManager.getConnection(url + db, user, pass);



pst = con.prepareStatement("insert into lib value(?,?)");

con.setAutoCommit(false);



pst.setString(1, "6");

pst.setString(2, "106");

pst.addBatch();



pst.setString(1, "7");

pst.setString(2, "107");

pst.addBatch();



pst.setString(1, "8");

pst.setString(2, "108");

pst.addBatch();



pst.executeBatch();



pst.close();



String sql = "select * from lib";

pst = con.prepareStatement(sql);



rs = pst.executeQuery();



System.out.println("rno\tlibno");

while (rs.next()) {

System.out.print(rs.getString(1) + " \t");

System.out.println(rs.getString(2));

}

rs.close();

pst.close();

con.close();



} catch (Exception e) {

e.printStackTrace();

}

}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: