testalterttable.java

来自「数据库远程同步软件NetBeans项目源文件 项目采用Jdesktop集成组件」· Java 代码 · 共 47 行

package com.qixuan.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;

import com.qixuan.jdbc.util.ALTERTablesUtil;
import java.sql.ResultSet;

public class TestAltertTable {

    public static void main(String[] args) throws SQLException {
        Connection connection = null;
        PreparedStatement pstmt = null;
        Statement stm = null;
        try {
           Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
			connection = DriverManager.getConnection("jdbc:sqlserver://hlsoft.9966.org:1433;DatabaseName=bp2;selectMethod=cursor","forever","admin123");
           
        /*
         *  Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            connection = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=bpoms", "forever", "admin123");
        connection = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;databaseName=bpoms;selectMethod=cursor;","forever","admin123");
        Class.forName("org.postgresql.Driver");
        connection = DriverManager.getConnection("jdbc:postgresql://localhost/diims","postgres","admin123");*/
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
       // ALTERTablesUtil.AddColumnByRecordFlag(connection);
      // ALTERTablesUtil.UpdateColumnRecordFlag(connection,0);
        StringBuffer sb=new StringBuffer();
        sb.append("SELECT * FROM depository ");
        sb.append("Inner Join store ON depository.depotCode = store.depotCode ");
        sb.append("WHERE store.citycode =  'SH RDC' ");
        sb.append("ORDER BY depository.id ASC ");
        stm=connection.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        int rs=stm.executeUpdate(sb.toString());
				System.out.println(rs);
    }
}