java通过jdbc对数据库的访问

连接jdbc需要引入jar包：mysql-connector-java-5.1.2-beta-bin.jar。

Connection conn = null;

         String sql;
         // MySQL的JDBC URL编写方式：jdbc:mysql://主机名称：连接端口/数据库的名称?参数=值
          // 避免中文乱码要指定useUnicode和characterEncoding
          // 执行数据库操作之前要在数据库管理系统上创建一个数据库，名字自己定，
         // 下面语句之前就要先创建javademo数据库
          String url = "jdbc:mysql://120.92.34.190:3306/entprophet?"
                 + "user=root&password=GbIcc@always&useUnicode=true&characterEncoding=UTF8";
          
         try {
             // 之所以要使用下面这条语句，是因为要使用MySQL的驱动，所以我们要把它驱动起来，
             // 可以通过Class.forName把它加载进去，也可以通过初始化来驱动起来，下面三种形式都可以
             Class.forName("com.mysql.jdbc.Driver");// 动态加载mysql驱动
             // or:
             // com.mysql.jdbc.Driver driver = new com.mysql.jdbc.Driver();
             // or：
             // new com.mysql.jdbc.Driver();
   
              System.out.println("成功加载MySQL驱动程序");
             // 一个Connection代表一个数据库连接
             conn = DriverManager.getConnection(url);
             // Statement里面带有很多方法，比如executeUpdate可以实现插入，更新和删除等
             
         /*  sql = "create table student(NO char(20),name varchar(20),primary key(NO))";
            int result = stmt.executeUpdate(sql);// executeUpdate语句会返回一个受影响的行数，如果返回-1就没有成功
             if (result != -1) {
                 System.out.println("创建数据表成功");*/
                /* sql = "insert into student(NO,name) values('2012001','陶伟基')";
                 result = stmt.executeUpdate(sql);
                  sql = "insert into student(NO,name) values('2012002','周小俊')";
                result = stmt.executeUpdate(sql);*/
            
            Statement stmt = conn.createStatement();
            for(int i=0;i<a.length;i++){
            sql = "select liscompshortname,new_code,sharecode,content from f_entprs_news where induid='"+Integer.toString(a[i])+"'";
                 ResultSet rs = stmt.executeQuery(sq
4000
l);// executeQuery会返回结果的集合，否则返回空值
                 System.out.println("第"+i+"个for");
                 int j = 0;
                  while (rs.next()) {
               
  Statement stmt1 = conn.createStatement();
//                      System.out.println(rs.getString(1) );// 入如果返回的是int类型可以用getInt()
                     System.out.println("--------------------------------");
//                      System.out.println(getTextFromHtml(rs.getString(1)));
                     String sss = getTextFromHtml(rs.getString(4));
                     List<String> list = chaifen(sss,positive,negative);
                     sql = "insert into singlenews values('"+rs.getString(1)+"','"+rs.getString(2)+"','"+rs.getString(3)+"','"+list.get(0)+"','"+list.get(1)+"','"+list.get(2)+"','"+list.get(3)+"','"+list.get(4)+"','"+list.get(5)+"','"+list.get(6)+"')";
             stmt1.executeUpdate(sql);
             j++;
             System.out.println("第"+j+"个while");
                  }
                 
            }
        } catch (SQLException e) {
             System.out.println("MySQL操作错误");
            e.printStackTrace();
         } catch (Exception e) {
             e.printStackTrace();
          } finally {
             conn.close();
         }