VPF::Проблема с обращением к процедуре Postgres

skif18

Дата 9.12.2009, 12:11 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 358
Регистрация: 17.5.2007
Где: Молдова, Кишинев

Репутация: нет
Всего: 1

Есть такая процедура на постгресе. При железном запуске с самого Постгреса она пашет...

Код


CREATE OR REPLACE FUNCTION "public"."updatezayavki" (c_dat text, c_kpot text, p_kol double precision, p_name text, p_user text, p_sum double precision, c_data timestamp) RETURNS integer AS
$body$
DECLARE
c_dat_ ALIAS FOR $1;
c_kpot_ ALIAS FOR $2;
p_kol_ ALIAS FOR $3;
p_name_ ALIAS FOR $4;
p_user_ ALIAS FOR $5;
p_sum_ ALIAS FOR $6;
c_data_ ALIAS FOR $7;
p_count int4;
BEGIN
     SELECT count(*) INTO p_count FROM zaiavki WHERE dat=$1 AND kpot=$2 AND kolvo=$3 AND nzprn=TRIM($4);
/*     SELECT count(*) INTO p_count FROM zaiavki WHERE dat=$1 AND kpot=$2 AND nzprn=TRIM($4);*/
     IF NOT FOUND THEN
        INSERT INTO zaiavki (dat, kpot, kolvo,kolzai,date_in,date_out, nzprn, kodopera,sumkolvo) VALUES ($1, $2, $3,$3,$7,CURRENT_TIMESTAMP,$4, $5, $6);
     ELSE
         UPDATE zaiavki SET kolvo = $3, kodopera = $5,date_in=$7,date_out=CURRENT_TIMESTAMP, sumkolvo=$6  WHERE dat=$1 AND kpot=$2 and nzprn=$4;
     END IF;
return 1;
END;
$body$
LANGUAGE 'plpgsql' VOLATILE RETURNS NULL ON NULL INPUT SECURITY INVOKER;

Но через java обращение - нет. Вот код обращения.

Код


    
    public static Connection getInsertConnection() throws Exception {
        String driver = "org.postgresql.Driver";
        String DBNAME = "sbit";
        String USERNAME = "postgres1";
        String PASSWORD = "syrus";
        Connection conn = null;
        if(conn==null){
        Class.forName(driver);
        conn = DriverManager.getConnection("jdbc:postgresql://192.168.4.3:5432/"+DBNAME,USERNAME,PASSWORD);
        }
        return conn;
      }

//--------------------------------------------------------------------------------------------
    public void setValueAt(Object value, int row, int column)
    {
      try
        { 
  if(value.equals("")==false){
    Connection connzay = getInsertConnection();
    connzay.setAutoCommit(false);
    String date =ZaiavkaProductii.dat;
    String kpot =ZaiavkaProductii.kpot;
    String kodopera =Zaiavki.codeUser;
    Double cen=Double.parseDouble(ZaiavkaProductii.cena);
    Double suma=cen*Double.parseDouble(dbRepresentationUp(column, value).toString().trim());
    connzay.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
    PreparedStatement proc1 =connzay.prepareCall("{ call updatezayavki(?::text, ?::text, ?::real, ?::text, ?::text,?::real,?::timestamp) }");
//    PreparedStatement proc1 =connzay.prepareCall("{ call updatezayavki1(?::text, ?::text, ?::real, ?::text, ?::text) }");
              proc1.setString(1, date);
              proc1.setString(2, kpot);
              proc1.setDouble(3, Double.parseDouble(dbRepresentationUp(column, value).toString().trim()));
              Vector row1 = (Vector)rows.elementAt(row);
              proc1.setString(4,dbRepresentationUp(column-2, row1.elementAt(column-2)).toString().trim());
              proc1.setString(5, kodopera);
              proc1.setDouble(6, suma);
              java.sql.Timestamp  expiration = new java.sql.Timestamp(new java.util.Date().getTime());             
              proc1.setTimestamp(7,expiration);
              proc1.executeUpdate();
              
//              System.out.println(" proc1.execute()="+ proc1.execute());

               System.out.println(" date="+ date);
               System.out.println(" kpot="+ kpot);
               System.out.println(" kolvo="+ Double.parseDouble(dbRepresentationUp(column, value).toString().trim()));
               System.out.println(" nzprn="+ dbRepresentationUp(column-2, row1.elementAt(column-2)).toString().trim());
               System.out.println("  kodopera="+  kodopera);
               System.out.println("time="+ expiration);
               System.out.println(" suma="+suma);
                          
//              System.out.println(" proc1.executeUpdate()="+ proc1.executeUpdate());
              
              Object val;
              val = tbRepresentation(column,value);
              Vector dataRow = (Vector)rows.elementAt(row);
              dataRow.setElementAt(val, column);
              fireTableDataChanged();
              proc1.close();
              connzay.commit();
              connzay.close();
              
//              conn.close();
          }
        }
        catch (Exception ex)
        {
/*            try {
                con.commit();
                con.close();
//                statement.close();
            } catch (SQLException e1) {
                // TODO Автоматически созданный блок catch
                e1.printStackTrace();
            } 
    */        ex.printStackTrace();
           System.err.println(ex);
        }
    }

Добавлено через 3 минуты и 8 секунд

Код


 System.out.println(proc1.executeUpdate());

Даете 0.

--------------------

LSD

Дата 9.12.2009, 12:26 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(skif18 @ 9.12.2009, 12:11

)

Даете 0.

И что тебя смущает

Цитата(JavaDoc)

Returns:
either (1) the row count for SQL Data Manipulation Language (DML) statements or (2) 0 for SQL statements that return nothing

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

skif18

Дата 9.12.2009, 12:30 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 358
Регистрация: 17.5.2007
Где: Молдова, Кишинев

Репутация: нет
Всего: 1

Но при запуске допустим в EMS SQL Manager при тех же данных она возвращает 1. т.е. выполняется.

Это сообщение отредактировал(а) skif18 - 9.12.2009, 12:30

--------------------

ivanovpv

Дата 9.12.2009, 14:42 (ссылка)

(нет голосов)

Загрузка ...

Варвар

Профиль
Группа: Участник
Сообщений: 639
Регистрация: 26.1.2005
Где: Москва

Репутация: 4
Всего: 28

Не надо путать то что возвращает хранимка от того, что возвращает вызов executeUpdate()

То что возвращает хранимка нужно регистрировать и нужно это делать не в PreparedStatement а в CallableStatement, типа так:

Код


CallableStatement call = conn.prepareCall("{?=call myFunc(?,?)}");
call.registerOutParameter(1, Types.INTEGER);
call.setInt(2, 1);
call.setString(3, "blah-blah");
call.execute();
int retValue = call.getInt(1);

--------------------

Aut viam inveniam aut faciam

skif18

Дата 9.12.2009, 15:16 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 358
Регистрация: 17.5.2007
Где: Молдова, Кишинев

Репутация: нет
Всего: 1

ivanovpv, у меня он ничего и не возвращает. она изменения делает. и все. зачем мне выходной параметр? 1 просто, чтоб видеть, что выполнилось.

Добавлено через 14 минут и 57 секунд
что самое интересное что какието строки она опдейтит , а какие-то нет. и почему не понятно.

--------------------

LSD

Дата 9.12.2009, 16:09 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(skif18 @ 9.12.2009, 15:16

)

что самое интересное что какието строки она опдейтит , а какие-то нет. и почему не понятно.

Это никак не связано с тем, что возвращает executeUpdate(). executeUpdate() возвращает код, который означает:

Цитата

either (1) the row count for SQL Data Manipulation Language (DML) statements or (2) 0 for SQL statements that return nothing

и все. Никто не полезет внутрь хранимой процедуры, чтобы выяснить сколько строк она изменила.

Цитата(skif18 @ 9.12.2009, 15:16

)

ivanovpv, у меня он ничего и не возвращает. она изменения делает. и все. зачем мне выходной параметр? 1 просто, чтоб видеть, что выполнилось.

Да, а

Код


     END IF;
return 1;
END;

это что тогда?

--------------------

skif18

Дата 12.12.2009, 10:37 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 358
Регистрация: 17.5.2007
Где: Молдова, Кишинев

Репутация: нет
Всего: 1

проблема была в процедуре... не хотела она принимать String после trim().
Убрали, запахала. Странно. Вышла проблема после смены Postgres 8.2 на Postgres 8.4

--------------------

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »